apache-storm - 工作人员正在不断重新启动，并在主管中出现 closedchannel 异常

Question

其中一位主管中的工作人员不断重新启动并收到 Closedchannel 异常。但是，如果在另一个环境中的另一个 Storm 集群中运行相同的拓扑，它运行时不会出现任何错误。

下面是我可以从 Storm UI 看到的错误。

java.lang.RuntimeException: java.nio.channels.ClosedChannelException 在 org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:103) 在 org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoordinator. java:69) 在 org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:129) 在 org.apache.storm.daemon.executor$fn__7990$fn__8005$fn__8036.invoke(executor.clj:648) 在 org .apache.storm.util$async_loop$fn__624.invoke(util.clj:484) 在 clojure.lang.AFn.run(AFn.java:22) 在 java.lang.Thread.run(Thread.java:745) 引起通过: kafka.network.BlockingChannel.send(BlockingChannel.scala:100) 上的 java.nio.channels.ClosedChannelException 在 kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:78) 上$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68) 在 kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:127) 在 kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79) 在 org.apache.storm 。K a fka.KafkaUtils.getOffset(KafkaUtils.java:75) 在 org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:65) 在 org.apache.storm.kafka.PartitionManager.(PartitionManager.java:94) 在org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98) ... 6 个月

谁能帮我找出确切的问题。如果需要更多信息，请告诉我。

Answer 1

我遇到了这个问题，问题是 ZooKeeper 主机名没有从工作主机解析。