You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/05/19 23:52:41 UTC
[16/24] git commit: Added debugging info to ShellSpout and pulled in
latest upstream master.
Added debugging info to ShellSpout and pulled in latest upstream master.
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/5ba09386
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/5ba09386
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/5ba09386
Branch: refs/heads/master
Commit: 5ba093862560aa3ca2cff002e2e38e1e37753670
Parents: 8030423
Author: John Gilmore <jg...@ml.sun.ac.za>
Authored: Mon Nov 18 16:31:44 2013 +0200
Committer: John Gilmore <jg...@ml.sun.ac.za>
Committed: Mon Nov 18 16:31:44 2013 +0200
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/spout/ShellSpout.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/5ba09386/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java b/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java
index bee56fe..6840938 100644
--- a/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java
+++ b/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java
@@ -94,6 +94,8 @@ public class ShellSpout implements ISpout {
_collector.emitDirect((int) task.longValue(), stream,
tuple, messageId);
}
+ } else {
+ throw new RuntimeException("Unknown command received: " + command);
}
}
} catch (IOException e) {