[
https://issues.apache.org/jira/browse/STORM-1578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhuo Liu updated STORM-1578:
----------------------------
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)
public void reportError(String stormId, String componentId, String node,
Long port, Throwable error)
public ClusterWorkerHeartbeat getWorkerHeartbeat(String stormId, String
node, Long port)
<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>
was:
(:port worker) is passed as Integer to java,
in STORM-1273, the port is defined as Long, which will cause
java.lang.ClassCastException.
<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>
> ClassCastException from Integer to Long for "port" in cluster.clj translation
> -----------------------------------------------------------------------------
>
> Key: STORM-1578
> URL: https://issues.apache.org/jira/browse/STORM-1578
> Project: Apache Storm
> Issue Type: Improvement
> Reporter: Zhuo Liu
>
> (: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)
> public void reportError(String stormId, String componentId, String node,
> Long port, Throwable error)
> public ClusterWorkerHeartbeat getWorkerHeartbeat(String stormId, String
> node, Long port)
> <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>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
