[
https://issues.apache.org/jira/browse/STORM-1645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15206201#comment-15206201
]
Abhishek Agarwal commented on STORM-1645:
-----------------------------------------
This problem exists only for the 0.10.x branch and it is a minor bug. So I am
not completely sure if this needs to be fixed.
> nimbus.thrift.port command line argument leads to
> java.lang.ClassCastException: java.lang.Long cannot be cast to
> java.lang.Integer
> ----------------------------------------------------------------------------------------------------------------------------------
>
> Key: STORM-1645
> URL: https://issues.apache.org/jira/browse/STORM-1645
> Project: Apache Storm
> Issue Type: Bug
> Components: storm-core
> Affects Versions: 0.10.0
> Reporter: Waatze Goldewijk
> Assignee: Abhishek Agarwal
>
> When you supply the commandline parameter for a custom Nimbus thrift port,
> the number value is interpreted as a Long, but internally used as an Integer.
> This leads to a ClassCastException.
> This is executed (redacted):
> /opt/storm/apache-storm-0.10.0/bin/storm kill -w 10 -c
> nimbus.thrift.port=6627 -c nimbus.host=vm0009 #{topology}"
> This is the output:
> ** [out :: vm0009] 2627 [main] INFO b.s.u.Utils - Using defaults.yaml from
> resources
> ** [out :: vm0009] 2795 [main] INFO b.s.u.Utils - Using storm.yaml from
> resources
> ** [out :: vm0009] 4262 [main] INFO b.s.u.Utils - Using defaults.yaml from
> resources
> ** [out :: vm0009] 4287 [main] INFO b.s.u.Utils - Using storm.yaml from
> resources
> ** [out :: vm0009] 4328 [main] INFO b.s.thrift - Connecting to Nimbus at
> vm0009:6627 as user:
> ** [out :: vm0009] 4328 [main] INFO b.s.u.Utils - Using defaults.yaml from
> resources
> ** [out :: vm0009] 4348 [main] INFO b.s.u.Utils - Using storm.yaml from
> resources
> ** [out :: vm0009] Exception in thread "main"
> ** [out :: vm0009] java.lang.ClassCastException: java.lang.Long cannot be
> cast to java.lang.Integer
> ** [out :: vm0009]
> ** [out :: vm0009] at
> backtype.storm.thrift$nimbus_client_and_conn.invoke(thrift.clj:75)
> ** [out :: vm0009]
> ** [out :: vm0009] at
> backtype.storm.thrift$nimbus_client_and_conn.invoke(thrift.clj:72)
> ** [out :: vm0009]
> ** [out :: vm0009]
> ** [out :: vm0009] at
> backtype.storm.command.kill_topology$_main.doInvoke(kill_topology.clj:26)
> ** [out :: vm0009]
> ** [out :: vm0009] at clojure.lang.RestFn.applyTo(RestFn.java:137)
> ** [out :: vm0009]
> ** [out :: vm0009] at backtype.storm.command.kill_topology.main(Unknown
> Source)
> ** [out :: vm0009]
> I have seen other related issues:
> https://issues.apache.org/jira/browse/STORM-1578
> I believe this is the same issue (internally using an Integer, but converting
> the input to a Long) in a different area.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
