工作者不断地被重启，并在supervisor中出现闭通道异常。

Question

在其中一个主管中的worker不断被重启，并出现闭通道异常。 但如果在另一个环境中的风暴集群中运行相同的拓扑，它在运行时没有给出任何错误。

下面是我在Storm UI中看到的错误。

java.lang.RuntimeException: java.nio.channels.ClosedChannelException at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:103) at org.apache. storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoordinator.java:69) at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:129) at org.apache.storm. daemon.executor$fn__7990$fn__8005$fn__8036.invoke(executor.clj:648) at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484) at clojure.lang.AFn.run(AFn. java:22) at java.lang.Thread.run(Thread.java:745) Caused by: java.nio.channels.ClosedChannelException at kafka.network.BlockingChannel.send(BlockingChannel. scala:100）在kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:78)在kafka.consumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68)在kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:127)在kafka.javaapi.consumer.SimpleConsumer. getOffsetsBefore(SimpleConsumer.scala:79) at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:75) at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils. java:65) at org.apache.storm.kafka.PartitionManager.(PartitionManager.java:94) at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98) .... 6 mo

Can any one please help me to find out the exact issue.Please let me know if need any more information.

Answer 1

我面临这个问题，问题是ZooKeeper主机名无法从worker主机解析。