Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2625#discussion_r179931950
--- Diff:
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java ---
@@ -339,6 +344,15 @@ public WorkerState(Map<String, Object> conf, IContext
mqContext, String topology
int maxTaskId = getMaxTaskId(componentToSortedTasks);
this.workerTransfer = new WorkerTransfer(this, topologyConf,
maxTaskId);
this.bpTracker = new BackPressureTracker(workerId, localTaskIds);
+ //
--- End diff --
â//â can be removed, and better to extract below to private method as
we did above.
---