Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/2241#discussion_r158041504 --- Diff: storm-client/src/jvm/org/apache/storm/daemon/Task.java --- @@ -192,7 +240,7 @@ private TopologyContext mkTopologyContext(StormTopology topology) throws IOExcep ConfigUtils.supervisorStormDistRoot(conf, workerData.getTopologyId())), ConfigUtils.workerPidsRoot(conf, workerData.getWorkerId()), taskId, - workerData.getPort(), workerData.getTaskIds(), + workerData.getPort(), workerData.getLocalTaskIds(), --- End diff -- Renamed method looks better to clarify the meaning. Nice improvement.
---