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

    https://github.com/apache/storm/pull/2433#discussion_r152703493
  
    --- Diff: 
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java ---
    @@ -647,6 +625,22 @@ public static boolean isConnectionReady(IConnection 
connection) {
             return executorsAssignedToThisWorker;
         }
     
    +    private Assignment getLocalAssignment(Map<String, Object> conf, 
IStormClusterState stormClusterState, String topologyId) {
    +        if (!ConfigUtils.isLocalMode(conf)) {
    +            try{
    --- End diff --
    
    space between y and {


---

Reply via email to