运行storm,启动失败了

发布于 2021-11-28 01:10:33 字数 4858 浏览 978 评论 5

#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 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(5

顾忌 2021-12-01 18:49:10

谢谢,找到;1

百思不得你姐 2021-12-01 18:47:45

storm.zookeeper.servers must be an Iterable of java.lang.String

鹤舞 2021-12-01 18:45:51

看看Storm项目实战具体操作吧:
http://edu.51cto.com/course/course_id-1274.html

躲猫猫 2021-12-01 18:32:40

这个文档很详细

青萝楚歌 2021-11-28 13:27:25
安装storm
	(1)配置storm环境变量
		在.bash_profile文件末尾添加storm的环境变量
		export STORM_HOME=/home/liufeng/Storm/apache-storm-0.9.1-incubating
		export PATH=$PATH:$STORM_HOME/bin
		建立自定义目录:mkdir ~/tmp/storm

	(2)配置storm.yaml
		1>配置storm的zookeeperserver配置
		storm.zookeeper.server:
		-     “222.18.159.122”
		-     “222.18.159.123”
		-     “222.18.159.125”
		-     “222.18.159.126”
		2>配置storm存储信息目录
		storm.local.dir : "/home/liufeng/tmp/storm"		
		(注意:冒号两边要有空格,不然会报错误:
		org.yaml.snakeyaml.scanner.ScannerException: while scanning a simple key; could not found expected ':';  in 'reader', line 26, column 2:
     	Storm.local.dir:)
		3>配置java.library.path 由于自动加载默认选项,因此此项可以不配置
		4>配置工作机器的工作端口
		supervisor.slots.ports 对于每一台工作机器,这个配置指定在这台工作机器上运行多少工作进程,每个进程使用一个独立端口来接收消息,这个配置同时也指定使用哪些端口。如果你在这里定义5个端口, storm会在这个机器上最多分配5个工作进程。如果分配3个端口,那么最多分配3个进程。
		示例如下:
		supervisor.slots.ports:
		-          6700
		-          6701
		-          6702
		-          6703
		注意:(配置选项之间的间隔不能用tab键来,不然会报如下错误:
			org.yaml.snakeyaml.scanner.ScannerException: while scanning for the next token; found character         't' that cannot start any token;  in 'reader', line 29, column7:)

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文