我已经运行了一年多的风暴-0.8.2集群。昨晚aws重启了监控机器。我尝试手动重新启动主管进程,但在启动时,我在日志中收到此错误消息。
014-10-15 19:48:04 supervisor [ERROR] Error on initialization of server mk-supervisor
java.net.UnknownHostException: domU-<aws internal ip>: domU-<aws internal ip>
at java.net.InetAddress.getLocalHost(InetAddress.java:1454)
at backtype.storm.util$local_hostname.invoke(util.clj:153)
at backtype.storm.daemon.supervisor$supervisor_data.invoke(supervisor.clj:181)
at backtype.storm.daemon.supervisor$fn__4729$exec_fn__1200__auto____4730.invoke(supervisor.clj:331)
at clojure.lang.AFn.applyToHelper(AFn.java:167)
at clojure.lang.AFn.applyTo(AFn.java:151)
at clojure.core$apply.invoke(core.clj:601)
at backtype.storm.daemon.supervisor$fn__4729$mk_supervisor__4754.doInvoke(supervisor.clj:327)
at clojure.lang.RestFn.invoke(RestFn.java:436)
at backtype.storm.daemon.supervisor$_launch.invoke(supervisor.clj:477)
at backtype.storm.daemon.supervisor$_main.invoke(supervisor.clj:506)
at clojure.lang.AFn.applyToHelper(AFn.java:159)
at clojure.lang.AFn.applyTo(AFn.java:151)
at backtype.storm.daemon.supervisor.main(Unknown Source)
我不是clojureMaven,但在backtype.storm.daemon.supervisor.clj的第215行,似乎可以在配置文件中设置localhost名称。
215 :my-hostname (if (contains? conf STORM-LOCAL-HOSTNAME)
216 (conf STORM-LOCAL-HOSTNAME)
217 (local-hostname))
这可能吗?我需要在哪个文件中设置此设置?此设置的正确键是什么?
或者我离基地太远了,需要做些别的事情让我的工人重新开始工作?
3条答案
按热度按时间3qpi33ja1#
我以前没有遇到过这种情况,但如果我是你,我会尝试:
清除storm使用的目录(在中配置的目录)
conf/storm.yaml
.如果上一步没有解决问题,请尝试将IPMap到操作系统主机文件中的主机名。
0x6upsns2#
将以下条目添加到storm.yaml文件
storm.local.hostname:“本地主机”
lfapxunr3#
我从用户邮件列表(storm.apache.com的用户)得到了帮助。您可以使用“storm.local.hostname”键在conf/storm.yaml文件中设置本地主机。