运行storm,启动失败了
#LicensedtotheApacheSoftwareFoundation(ASF)underone #ormorecontributorlicenseagreements.SeetheNOTICEfile #distributedwiththisworkforadditionalinformation #regardingcopyrightownership.TheASFlicensesthisfile #toyouundertheApacheLicense,Version2.0(the #"License");youmaynotusethisfileexceptincompliance #withtheLicense.YoumayobtainacopyoftheLicenseat # #http://www.apache.org/licenses/LICENSE-2.0 # #Unlessrequiredbyapplicablelaworagreedtoinwriting,software #distributedundertheLicenseisdistributedonan"ASIS"BASIS, #WITHOUTWARRANTIESORCONDITIONSOFANYKIND,eitherexpressorimplied. #SeetheLicenseforthespecificlanguagegoverningpermissionsand #limitationsundertheLicense. ###########TheseMUSTbefilledinforastormconfiguration storm.zookeeper.servers: -"master" -"slave1" storm.local.dir:"/bigdata/storm/data" storm.zookeeper.port:2181 nimbus.host:"master" #supervisor.slots.ports : # -6700 # -6701 # -6702 # -6703 supervisor.slots.ports: -6700 -6701 -6702 -6703 ###ui.*configsareforthe192.168.2.230 ##我这里修改了storm的ui端口 #ui.port:8081 ######Thesemayoptionallybefilledin: # ##Listofcustomserializations #topology.kryo.register: #-org.mycompany.MyType #-org.mycompany.MyType2:org.mycompany.MyType2Serializer # ##Listofcustomkryodecorators #topology.kryo.decorators: #-org.mycompany.MyDecorator # ##Locationsofthedrpcservers #drpc.servers: #-"server1" #-"server2" ##MetricsConsumers #topology.metrics.consumer.register: #-class:"backtype.storm.metric.LoggingMetricsConsumer" #parallelism.hint:1 #-class:"org.mycompany.MyMetricsConsumer" #parallelism.hint:1 #argument: #-endpoint:"metrics-collector.mycompany.org"
root@slave1 ~]# storm supervisor Exception in thread "main" java.lang.IllegalArgumentException: Field storm.zookeeper.servers must be an Iterable of java.lang.String at backtype.storm.ConfigValidation$1.validateField(ConfigValidation.java:63) at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:497) 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:117) at backtype.storm.config$read_storm_config.invoke(config.clj:122) 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) Exception in thread "main" java.lang.IllegalArgumentException: Field storm.zookeeper.servers must be an Iterable of java.lang.String at backtype.storm.ConfigValidation$1.validateField(ConfigValidation.java:63) at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:497) 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:117) at backtype.storm.config$read_storm_config.invoke(config.clj:122) 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) Exception in thread "main" java.lang.IllegalArgumentException: Field storm.zookeeper.servers must be an Iterable of java.lang.String at backtype.storm.ConfigValidation$1.validateField(ConfigValidation.java:63) at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:497) 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:117) at backtype.storm.config$read_storm_config.invoke(config.clj:122) 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)
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(5)
谢谢,找到;1
storm.zookeeper.servers must be an Iterable of java.lang.String
看看Storm项目实战具体操作吧:
http://edu.51cto.com/course/course_id-1274.html
这个文档很详细