You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@storm.apache.org by HeartSaVioR <gi...@git.apache.org> on 2017/12/20 14:50:09 UTC

[GitHub] storm pull request #2241: STORM-2306 : Messaging subsystem redesign.

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

    https://github.com/apache/storm/pull/2241#discussion_r158042030
  
    --- Diff: storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java ---
    @@ -186,9 +201,11 @@ public Runnable getSuicideCallback() {
         final AtomicBoolean isTopologyActive;
         final AtomicReference<Map<String, DebugOptions>> stormComponentToDebug;
     
    -    // executors and taskIds running in this worker
    +    // executors and localTaskIds running in this worker
         final Set<List<Long>> executors;
    --- End diff --
    
    Based on the comment, this can be also `localExecutors`.


---