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