remove instanceof check

xiaokang · xiaokang · commit 5b071c0bdf01 · 2013-11-05T17:29:41.000+08:00
diff --git a/storm-core/src/jvm/backtype/storm/task/ShellBolt.java b/storm-core/src/jvm/backtype/storm/task/ShellBolt.java
@@ -73,7 +73,7 @@ public ShellBolt(String... command) {
     public void prepare(Map stormConf, TopologyContext context,
                         final OutputCollector collector) {
         Object maxPending = stormConf.get(Config.TOPOLOGY_SHELLBOLT_MAX_PENDING);
-        if (maxPending != null && maxPending instanceof Number) {
+        if (maxPending != null) {
            this._pendingWrites = new LinkedBlockingQueue(((Number)maxPending).intValue());
         }
         _rand = new Random();

Original file line number	Diff line number	Diff line change
`@@ -73,7 +73,7 @@ public ShellBolt(String... command) {`
`73`	`73`	`public void prepare(Map stormConf, TopologyContext context,`
`74`	`74`	`final OutputCollector collector) {`
`75`	`75`	`Object maxPending = stormConf.get(Config.TOPOLOGY_SHELLBOLT_MAX_PENDING);`
`76`		`- if (maxPending != null && maxPending instanceof Number) {`
	`76`	`+ if (maxPending != null) {`
`77`	`77`	`this._pendingWrites = new LinkedBlockingQueue(((Number)maxPending).intValue());`
`78`	`78`	`}`
`79`	`79`	`_rand = new Random();`