storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [2/4] git commit: Change exception type to IllegalArgumentException
Date Thu, 07 Aug 2014 20:57:43 GMT
Change exception type to IllegalArgumentException


Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/2ea20270
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/2ea20270
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/2ea20270

Branch: refs/heads/master
Commit: 2ea202704a509c0bea14438beb65443f33517ebc
Parents: bf8e456
Author: Itai Frenkel <itai@ryzyco.com>
Authored: Thu Jul 10 19:10:38 2014 +0300
Committer: Itai Frenkel <itai@ryzyco.com>
Committed: Thu Jul 10 19:10:38 2014 +0300

----------------------------------------------------------------------
 storm-core/src/jvm/backtype/storm/spout/ShellSpout.java | 2 +-
 storm-core/src/jvm/backtype/storm/task/ShellBolt.java   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/2ea20270/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 e3865fc..89502ed 100644
--- a/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java
+++ b/storm-core/src/jvm/backtype/storm/spout/ShellSpout.java
@@ -129,7 +129,7 @@ public class ShellSpout implements ISpout {
                 ShellMsg shellMsg = _process.readShellMsg();
                 String command = shellMsg.getCommand();
                 if (command == null) {
-                    throw new UnsupportedOperationException("Command not found in spout message:
" + shellMsg);
+                    throw new IllegalArgumentException("Command not found in spout message:
" + shellMsg);
                 }
                 if (command.equals("sync")) {
                     return;

http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/2ea20270/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 946f037..eb9e714 100644
--- a/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
+++ b/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
@@ -116,7 +116,7 @@ public class ShellBolt implements IBolt {
 
                         String command = shellMsg.getCommand();
                         if (command == null) {
-                            throw new UnsupportedOperationException("Command not found in
bolt message: " + shellMsg);
+                            throw new IllegalArgumentException("Command not found in bolt
message: " + shellMsg);
                         }
                         if(command.equals("ack")) {
                             handleAck(shellMsg.getId());


Mime
View raw message