Github user revans2 commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2363#discussion_r145723449
  
    --- Diff: storm-client/src/jvm/org/apache/storm/utils/NimbusClient.java ---
    @@ -126,7 +137,9 @@ public static NimbusClient 
getConfiguredClientAs(Map<String, Object> conf, Strin
                     nimbusSummary = client.getClient().getLeader();
                     if (nimbusSummary != null) {
                         String leaderNimbus = nimbusSummary.get_host() + ":" + 
nimbusSummary.get_port();
    -                    LOG.info("Found leader nimbus : {}", leaderNimbus);
    +                    if (LOG.isDebugEnabled() || 
shouldLogLeader(leaderNimbus)) {
    --- End diff --
    
    I will adjust it so it is clearer.


---

Reply via email to