Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2363#discussion_r147159038
--- Diff: storm-client/src/jvm/org/apache/storm/utils/NimbusClient.java ---
@@ -86,7 +86,22 @@ public static NimbusClient
getConfiguredClient(Map<String, Object> conf) {
public static NimbusClient getConfiguredClient(Map<String, Object>
conf, Integer timeout) {
return getConfiguredClientAs(conf, null, timeout);
}
-
+
+ private static String oldLeader = "";
+
+ private static synchronized boolean shouldLogLeader(String leader) {
+ if (LOG.isDebugEnabled()) {
+ //If debug logging is turned on we shoudl just log the leader
all the time....
--- End diff --
nit: shoudl -> should
---
