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.


---

Reply via email to