[
https://issues.apache.org/jira/browse/STORM-173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13965463#comment-13965463
]
Danijel Schiavuzzi edited comment on STORM-173 at 4/11/14 10:01 AM:
--------------------------------------------------------------------
This is still happening on 0.9.1-incubating even though the Release notes seem
to indicate it's fixed.
[~xumingming], [~ptgoetz] please reopen this task if possible. Thanks!
Example:
{noformat}
$ storm jar my-topology-jar-with-dependencies.jar
org.storm.topologies.MyTopology -c
topology.trident.batch.emit.interval.millis=1000
Exception in thread "main" java.lang.IllegalArgumentException: field
topology.trident.batch.emit.interval.millis '1000' must be a 'java.lang.Number'
at
backtype.storm.config$eval716$fn$reify__718.validateField(config.clj:58)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
at
backtype.storm.config$validate_configs_with_schemas.invoke(config.clj:112)
at backtype.storm.config$read_storm_config.invoke(config.clj:117)
at backtype.storm.command.config_value$_main.invoke(config_value.clj:22)
at clojure.lang.AFn.applyToHelper(AFn.java:161)
at clojure.lang.AFn.applyTo(AFn.java:151)
at backtype.storm.command.config_value.main(Unknown Source)
{noformat}
was (Author: dschiavu):
This is still happening on 0.9.1-incubating even though the Release notes seem
to indicate it's fixed.
Example:
{noformat}
$ storm jar my-topology-jar-with-dependencies.jar
org.storm.topologies.MyTopology -c
topology.trident.batch.emit.interval.millis=1000
Exception in thread "main" java.lang.IllegalArgumentException: field
topology.trident.batch.emit.interval.millis '1000' must be a 'java.lang.Number'
at
backtype.storm.config$eval716$fn$reify__718.validateField(config.clj:58)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
at
backtype.storm.config$validate_configs_with_schemas.invoke(config.clj:112)
at backtype.storm.config$read_storm_config.invoke(config.clj:117)
at backtype.storm.command.config_value$_main.invoke(config_value.clj:22)
at clojure.lang.AFn.applyToHelper(AFn.java:161)
at clojure.lang.AFn.applyTo(AFn.java:151)
at backtype.storm.command.config_value.main(Unknown Source)
{noformat}
> use "-c " command to define Number config value will generate
> ClassCastException
> --------------------------------------------------------------------------------
>
> Key: STORM-173
> URL: https://issues.apache.org/jira/browse/STORM-173
> Project: Apache Storm (Incubating)
> Issue Type: Bug
> Reporter: caofangkun
> Priority: Minor
>
> storm -c topology.workers=3 -c storm.zookeeper.root=/storm/cluster001 jar
> ./storm-starter-0.0.1-SNAPSHOT.jar storm.starter.WordCountTopology2
> WordCountTopology2
> Will generate SerConf like this :
> Submitting topology WordCountTopology2 in distributed mode with conf
> {"storm.zookeeper.root":"\/storm\/cluster001","topology.workers":"3","topology.debug":true}
> but "topology.workers":"3" is wrong and should be "topology.workers":3
> And can find errors in $STOMR_HOME/logs/nimbus.log as following:
> 2013-12-10 11:18:44 o.a.t.s.TNonblockingServer [ERROR] Unexpected exception
> while invoking!
> java.lang.ClassCastException: java.lang.String cannot be cast to
> java.lang.Number
> at backtype.storm.thrift$mk_plain_component_common.doInvoke(thrift.clj:93)
> ~[storm-core-0.9.0-rc2.jar:na]
> at clojure.lang.RestFn.invoke(RestFn.java:494) ~[clojure-1.4.0.jar:na]
> at backtype.storm.thrift$mk_bolt_spec_STAR_.doInvoke(thrift.clj:158)
> ~[storm-core-0.9.0-rc2.jar:na]
> at clojure.lang.RestFn.invoke(RestFn.java:573) ~[clojure-1.4.0.jar:na]
> at backtype.storm.daemon.common$add_acker_BANG_.invoke(common.clj:183)
> ~[storm-core-0.9.0-rc2.jar:na]
> at backtype.storm.daemon.common$system_topology_BANG_.invoke(common.clj:280)
> ~[storm-core-0.9.0-rc2.jar:na]
> at
> backtype.storm.daemon.nimbus$fn__5822$exec_fn__1273__auto__$reify__5835.submitTopologyWithOpts(nimbus.clj:931)
> ~[storm-core-0.9.0-rc2.jar:na]
> at
> backtype.storm.daemon.nimbus$fn__5822$exec_fn__1273__auto__$reify__5835.submitTopology(nimbus.clj:949)
> ~[storm-core-0.9.0-rc2.jar:na]
> at
> backtype.storm.generated.Nimbus$Processor$submitTopology.getResult(Nimbus.java:1223)
> ~[storm-core-0.9.0-rc2.jar:na]
> at
> backtype.storm.generated.Nimbus$Processor$submitTopology.getResult(Nimbus.java:1211)
> ~[storm-core-0.9.0-rc2.jar:na]
> at org.apache.thrift7.ProcessFunction.process(ProcessFunction.java:32)
> ~[libthrift7-0.7.0-2.jar:0.7.0-2]
> at org.apache.thrift7.TBaseProcessor.process(TBaseProcessor.java:34)
> ~[libthrift7-0.7.0-2.jar:0.7.0-2]
> at
> org.apache.thrift7.server.TNonblockingServer$FrameBuffer.invoke(TNonblockingServer.java:632)
> ~[libthrift7-0.7.0-2.jar:0.7.0-2]
> at org.apache.thrift7.server.THsHaServer$Invocation.run(THsHaServer.java:201)
> [libthrift7-0.7.0-2.jar:0.7.0-2]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> [na:1.6.0_37]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> [na:1.6.0_37]
> at java.lang.Thread.run(Thread.java:662) [na:1.6.0_37]
--
This message was sent by Atlassian JIRA
(v6.2#6252)
