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`.
---
