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

    https://github.com/apache/storm/pull/2531#discussion_r164024269
  
    --- Diff: 
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
    @@ -2638,6 +2647,34 @@ private int getNumOfAckerExecs(Map<String, Object> 
totalConf, StormTopology topo
             }
         }
     
    +    private void upsertWorkerTokensInCreds(Map<String, String> creds, 
String user, String topologyId) {
    +        if (workerTokenManager != null) {
    --- End diff --
    
    updateWorkerTokensInCreds ?


---

Reply via email to