Skip to content

Commit b3c0712

Browse files
committed
code cleanup
1 parent 738a65b commit b3c0712

2 files changed

Lines changed: 7 additions & 4 deletions

File tree

ql/src/java/org/apache/hadoop/hive/ql/exec/tez/WmTezSession.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -68,15 +68,15 @@ private final static class ActualWmState {
6868
private final ActualWmState actualState = new ActualWmState();
6969

7070
public WmTezSession(
71-
WorkloadManager manager, SessionExpirationTracker expiration, TezSessionState superr) {
72-
super(manager, expiration, superr);
71+
WorkloadManager manager, SessionExpirationTracker expiration, TezSessionState baseSession) {
72+
super(manager, expiration, baseSession);
7373
wmManager = manager;
7474
isDelayedMove = false;
7575
}
7676

7777
@VisibleForTesting
78-
WmTezSession(Manager testParent, SessionExpirationTracker expiration, TezSessionState superr) {
79-
super(testParent, expiration, superr);
78+
WmTezSession(Manager testParent, SessionExpirationTracker expiration, TezSessionState baseSession) {
79+
super(testParent, expiration, baseSession);
8080
wmManager = null;
8181
isDelayedMove = false;
8282
}

ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezExternalSessionsRegistryClient.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@ public void testDummyExternalSessionsRegistry() {
2828
HiveConf conf = new HiveConf();
2929
conf.setVar(HiveConf.ConfVars.HIVE_SERVER2_TEZ_EXTERNAL_SESSIONS_REGISTRY_CLASS,
3030
DummyExternalSessionsRegistry.class.getName());
31+
// TODO: change this to TezConfiguration.TEZ_AM_REGISTRY_NAMESPACE after Tez 1.0.0 is released.
3132
conf.set("tez.am.registry.namespace", "dummy");
3233
ExternalSessionsRegistry externalSessionsRegistry = ExternalSessionsRegistry.getClient(conf);
3334
assertTrue(externalSessionsRegistry instanceof DummyExternalSessionsRegistry);
@@ -36,7 +37,9 @@ public void testDummyExternalSessionsRegistry() {
3637
@Test
3738
public void testTezExternalSessionsRegistry() {
3839
HiveConf conf = new HiveConf();
40+
// TODO: change this to TezConfiguration.TEZ_AM_ZOOKEEPER_QUORUM after Tez 1.0.0 is released.
3941
conf.set("tez.am.zookeeper.quorum", "test-quorum");
42+
// TODO: change this to TezConfiguration.TEZ_AM_REGISTRY_NAMESPACE after Tez 1.0.0 is released.
4043
conf.set("tez.am.registry.namespace", "tez");
4144
conf.setVar(HiveConf.ConfVars.HIVE_SERVER2_TEZ_EXTERNAL_SESSIONS_REGISTRY_CLASS,
4245
ZookeeperExternalSessionsRegistryClient.class.getName());

0 commit comments

Comments
 (0)