Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2533#discussion_r163767878
--- Diff: storm-client/src/jvm/org/apache/storm/executor/Executor.java ---
@@ -387,11 +387,13 @@ protected void setupTicks(boolean isSpout) {
LOG.info("Timeouts disabled for executor {}:{}",
componentId, executorId);
} else {
StormTimer timerTask = workerData.getUserTimer();
- TupleImpl tuple = new TupleImpl(workerTopologyContext, new
Values(tickTimeSecs),
- (int) Constants.SYSTEM_TASK_ID,
Constants.SYSTEM_TICK_STREAM_ID);
- final List<AddressedTuple> tickTuple =
- Lists.newArrayList(new
AddressedTuple(AddressedTuple.BROADCAST_DEST, tuple));
- timerTask.scheduleRecurring(tickTimeSecs, tickTimeSecs, ()
-> receiveQueue.publish(tickTuple));
+ timerTask.scheduleRecurring(tickTimeSecs, tickTimeSecs, ()
-> {
--- End diff --
Addressed. Commit amended since it is a tiny change.
---
