Skip to content

Commit 86f90cf

Browse files
committed
Fix formatting issues
1 parent 7f6b08f commit 86f90cf

1 file changed

Lines changed: 22 additions & 22 deletions

File tree

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

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -127,30 +127,30 @@ public void stateChanged(CuratorFramework client, ConnectionState newState) {
127127
this.claimsCache = CuratorCache.build(client, claimsPath);
128128
CuratorCacheListener claimsListener = CuratorCacheListener.builder().forCreates(
129129
childData -> {
130-
if (childData == null) {
131-
return;
132-
}
133-
String applicationId = getApplicationId(childData);
134-
synchronized (lock) {
135-
available.remove(applicationId);
136-
}
137-
}).forDeletes(
130+
if (childData == null) {
131+
return;
132+
}
133+
String applicationId = getApplicationId(childData);
134+
synchronized (lock) {
135+
available.remove(applicationId);
136+
}
137+
}).forDeletes(
138138
childData -> {
139-
if (childData == null) {
140-
return;
141-
}
142-
String applicationId = getApplicationId(childData);
143-
synchronized (lock) {
144-
if (!taken.contains(applicationId)) {
145-
if (cache.get(sessionsPath + "/" + applicationId).isPresent()) {
146-
available.add(applicationId);
147-
lock.notifyAll();
148-
} else {
149-
LOG.info("Ignoring AM claim removal for {} because the base AM node no longer exists.", applicationId);
139+
if (childData == null) {
140+
return;
150141
}
151-
}
152-
}
153-
}).build();
142+
String applicationId = getApplicationId(childData);
143+
synchronized (lock) {
144+
if (!taken.contains(applicationId)) {
145+
if (cache.get(sessionsPath + "/" + applicationId).isPresent()) {
146+
available.add(applicationId);
147+
lock.notifyAll();
148+
} else {
149+
LOG.info("Ignoring AM claim removal for {} because the base AM node no longer exists.", applicationId);
150+
}
151+
}
152+
}
153+
}).build();
154154
claimsCache.listenable().addListener(claimsListener);
155155
claimsCache.start();
156156

0 commit comments

Comments
 (0)