Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
2.0.0
-
None
-
None
Description
(:port worker) is passed as Integer to java,
in STORM-1273, the port is defined as Long, which will cause java.lang.ClassCastException.
Funtions might be afftected:
public void workerBackpressure(String stormId, String node, Long port, boolean on) (confirmed)
<code>
8953 java.lang.ClassCastException: Cannot cast java.lang.Integer to java.lang.Long
8954 at java.lang.Class.cast(Class.java:3369) ~[?:1.8.0_60]
8955 at clojure.lang.Reflector.boxArg(Reflector.java:427) ~[clojure-1.7.0.jar:?]
8956 at clojure.lang.Reflector.boxArgs(Reflector.java:460) ~[clojure-1.7.0.jar:?]
8957 at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:58) ~[clojure-1.7.0.jar:?]
8958 at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28) ~[clojure-1.7.0.jar:?]
8959 at org.apache.storm.daemon.worker$mk_backpressure_handler$reify__7649.onEvent(worker.clj:160) [storm-core-2.0.0-SNAPSHOT.jar:2.0.0-SNAPSHOT
<code>