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:38 UTC
[18/27] storm git commit: Resolve NPE that can occur if there is no
SourceComponent in a Tuple
Resolve NPE that can occur if there is no SourceComponent in a Tuple
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5faa782a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5faa782a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5faa782a
Branch: refs/heads/0.10.x-branch
Commit: 5faa782ab2c8732579f1693d74c8d1e1722c3942
Parents: 63f331f
Author: Niels Basjes <ni...@basjes.nl>
Authored: Thu Dec 11 12:35:01 2014 +0100
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri May 15 15:28:27 2015 -0400
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/tuple/TupleImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/5faa782a/storm-core/src/jvm/backtype/storm/tuple/TupleImpl.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/tuple/TupleImpl.java b/storm-core/src/jvm/backtype/storm/tuple/TupleImpl.java
index 7ff2c8c..40ad11c 100644
--- a/storm-core/src/jvm/backtype/storm/tuple/TupleImpl.java
+++ b/storm-core/src/jvm/backtype/storm/tuple/TupleImpl.java
@@ -215,8 +215,8 @@ public class TupleImpl extends IndifferentAccessMap implements Seqable, Indexed,
}
public boolean isTick() {
- return this.getSourceComponent().equals(Constants.SYSTEM_COMPONENT_ID) &&
- this.getSourceStreamId().equals(Constants.SYSTEM_TICK_STREAM_ID);
+ return Constants.SYSTEM_COMPONENT_ID.equals(this.getSourceComponent()) &&
+ Constants.SYSTEM_TICK_STREAM_ID.equals(this.getSourceStreamId());
}
public MessageId getMessageId() {