You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2017/10/04 19:26:32 UTC
[1/2] storm git commit: [STORM-2769] Fast-fail if output streamId is
null
Repository: storm
Updated Branches:
refs/heads/master 4b2d6dc32 -> cbe1e372a
[STORM-2769] Fast-fail if output streamId is null
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/e20394f9
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/e20394f9
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/e20394f9
Branch: refs/heads/master
Commit: e20394f91246b9d936f8ef3bf130343d7c4f1a03
Parents: c607d04
Author: Ethan Li <et...@gmail.com>
Authored: Tue Oct 3 13:54:18 2017 -0500
Committer: Ethan Li <et...@gmail.com>
Committed: Tue Oct 3 15:03:16 2017 -0500
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/topology/OutputFieldsGetter.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/e20394f9/storm-client/src/jvm/org/apache/storm/topology/OutputFieldsGetter.java
----------------------------------------------------------------------
diff --git a/storm-client/src/jvm/org/apache/storm/topology/OutputFieldsGetter.java b/storm-client/src/jvm/org/apache/storm/topology/OutputFieldsGetter.java
index abc939c..fa4ca84 100644
--- a/storm-client/src/jvm/org/apache/storm/topology/OutputFieldsGetter.java
+++ b/storm-client/src/jvm/org/apache/storm/topology/OutputFieldsGetter.java
@@ -39,6 +39,9 @@ public class OutputFieldsGetter implements OutputFieldsDeclarer {
}
public void declareStream(String streamId, boolean direct, Fields fields) {
+ if (null == streamId) {
+ throw new IllegalArgumentException("streamId can't be null");
+ }
if(_fields.containsKey(streamId)) {
throw new IllegalArgumentException("Fields for " + streamId + " already set");
}
[2/2] storm git commit: Merge branch 'STORM-2769' of
https://github.com/Ethanlm/storm into STORM-2769-merge
Posted by sr...@apache.org.
Merge branch 'STORM-2769' of https://github.com/Ethanlm/storm into STORM-2769-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/cbe1e372
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/cbe1e372
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/cbe1e372
Branch: refs/heads/master
Commit: cbe1e372a462e6c8a6a19edf53774302940894a9
Parents: 4b2d6dc e20394f
Author: Stig Rohde Døssing <sr...@apache.org>
Authored: Wed Oct 4 21:24:57 2017 +0200
Committer: Stig Rohde Døssing <sr...@apache.org>
Committed: Wed Oct 4 21:24:57 2017 +0200
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/topology/OutputFieldsGetter.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------