Use isTick in all relevant places to avoid code duplication.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8888ae63 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8888ae63 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8888ae63 Branch: refs/heads/master Commit: 8888ae631360ad124af9c480d2f8b621b9c51727 Parents: 73e54a8 Author: Niels Basjes <[email protected]> Authored: Wed Oct 1 11:53:17 2014 +0200 Committer: Niels Basjes <[email protected]> Committed: Wed Oct 1 11:53:17 2014 +0200 ---------------------------------------------------------------------- storm-core/src/jvm/storm/trident/topology/TridentBoltExecutor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/8888ae63/storm-core/src/jvm/storm/trident/topology/TridentBoltExecutor.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/storm/trident/topology/TridentBoltExecutor.java b/storm-core/src/jvm/storm/trident/topology/TridentBoltExecutor.java index 4dfccc6..da4c1a5 100644 --- a/storm-core/src/jvm/storm/trident/topology/TridentBoltExecutor.java +++ b/storm-core/src/jvm/storm/trident/topology/TridentBoltExecutor.java @@ -299,7 +299,7 @@ public class TridentBoltExecutor implements IRichBolt { @Override public void execute(Tuple tuple) { - if(tuple.getSourceStreamId().equals(Constants.SYSTEM_TICK_STREAM_ID)) { + if(tuple.isTick()) { long now = System.currentTimeMillis(); if(now - _lastRotate > _messageTimeoutMs) { _batches.rotate();
