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:36 UTC
[11/24] git commit: Allow for null boltMsg when polling
Allow for null boltMsg when polling
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/5699373b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/5699373b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/5699373b
Branch: refs/heads/master
Commit: 5699373be3842310171aa9b51059d94c03dca82a
Parents: 32b3718
Author: John Gilmore <jg...@ml.sun.ac.za>
Authored: Wed Oct 9 17:00:10 2013 +0200
Committer: John Gilmore <jg...@ml.sun.ac.za>
Committed: Wed Oct 9 17:00:10 2013 +0200
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/task/ShellBolt.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/5699373b/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/task/ShellBolt.java b/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
index fb07986..1649fbe 100644
--- a/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
+++ b/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
@@ -116,8 +116,8 @@ public class ShellBolt implements IBolt {
_process.writeBoltMsg((BoltMsg)write);
} else if (write instanceof List<?>) {
_process.writeTaskIds((List<Integer>)write);
- } else {
- throw new RuntimeException("Cannot write object to bolt:\n" + write.toString());
+ } else if (write != null) {
+ throw new RuntimeException("Unknown class type to write: " + write.getClass().getName());
}
} catch (InterruptedException e) {
} catch (Throwable t) {