[
https://issues.apache.org/jira/browse/STORM-1645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15206570#comment-15206570
]
Alexander Swen commented on STORM-1645:
---------------------------------------
For us, running multiple storm nimbus instances on one server this is quite an
annoying problem as we have to set three ports for the nimbus instances to
listen on. So, we would be very happy if this bug gets solved. Thanks in
advance for reconsidering this.
Best regards,
Alex
> 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)
