Github user roshannaik commented on a diff in the pull request:
https://github.com/apache/storm/pull/2502#discussion_r161358582
--- Diff: storm-client/src/jvm/org/apache/storm/executor/Executor.java ---
@@ -196,19 +197,21 @@ public static Executor mkExecutor(WorkerState
workerState, List<Long> executorId
executor.stats = new
BoltExecutorStats(ConfigUtils.samplingRate(executor.getStormConf()),ObjectReader.getInt(executor.getStormConf().get(Config.NUM_STAT_BUCKETS)));
}
+ int minId = Integer.MAX_VALUE;
Map<Integer, Task> idToTask = new HashMap<>();
for (Integer taskId : taskIds) {
+ minId = Math.min(minId, taskId);
try {
Task task = new Task(executor, taskId);
- executor.sendUnanchored(
- task, StormCommon.SYSTEM_STREAM_ID, new
Values("startup"), executor.getExecutorTransfer());
+ task.sendUnanchored( StormCommon.SYSTEM_STREAM_ID, new
Values("startup"), executor.getExecutorTransfer(), null); // TODO: Roshan: does
this get delivered/handled anywhere ?
--- End diff --
I don't care too much, will retain if it has some use.
---
