[storm] branch master updated: [STORM-3491] BoltReaderRunnable shouldn't throw IllegalArgumentException for sync command

[et...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

ethanli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git


The following commit(s) were added to refs/heads/master by this push:
     new 26c5bfd  [STORM-3491] BoltReaderRunnable shouldn't throw IllegalArgumentException for sync command
     new 4a1159d  Merge pull request #3106 from Ethanlm/STORM-3491
26c5bfd is described below

commit 26c5bfdf36b737a7ba5a4ac1cf700101b6293de3
Author: Ethan Li <et...@gmail.com>
AuthorDate: Mon Aug 19 12:41:00 2019 -0500

    [STORM-3491] BoltReaderRunnable shouldn't throw IllegalArgumentException for sync command
---
 storm-client/src/jvm/org/apache/storm/task/ShellBolt.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/storm-client/src/jvm/org/apache/storm/task/ShellBolt.java b/storm-client/src/jvm/org/apache/storm/task/ShellBolt.java
index dfb6383..0fe3efb 100644
--- a/storm-client/src/jvm/org/apache/storm/task/ShellBolt.java
+++ b/storm-client/src/jvm/org/apache/storm/task/ShellBolt.java
@@ -363,8 +363,7 @@ public class ShellBolt implements IBolt {
                             handleMetrics(shellMsg);
                             break;
                         default:
-                            throw new IllegalArgumentException(String.format("command %s is not supported",
-                                    command));
+                            break;
                     }
                 } catch (InterruptedException e) {
                     // It's likely that Bolt is shutting down so no need to die.