You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/05/15 23:27:35 UTC
[15/27] storm git commit: Use isTick in all relevant places to avoid
code duplication.
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/6537b369
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6537b369
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6537b369
Branch: refs/heads/0.10.x-branch
Commit: 6537b3691378835ad135799fdb5a2cedf7ab4649
Parents: 62385d7
Author: Niels Basjes <nb...@bol.com>
Authored: Wed Oct 1 11:53:17 2014 +0200
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri May 15 15:27:13 2015 -0400
----------------------------------------------------------------------
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/6537b369/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();