supervisor.log中错误消息:Storm Supervisor无法同时创建stormClusterState,它在zk的/storm/supervisor目录中为空。可以启动nimbus进程,但无法启动Supervisor。为什么?
the error msg in supervisor.log: ava.lang.Error: java.lang.RuntimeException: org.apache.storm.shade.org.apache.zookeeper.KeeperExceptionsConnectionLossException: KeeperErrorCode = ConnectionLoss for /stom at org.apache.storm.utils.Utils.handleUncaughtException(Utils.java:663)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.utils.Utils.handleUncaughtException(Utils.java:667)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.utils.Utils.lambda$createDefaultUncaughtExceptionHandler$2(Utils.java:1047)[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.utils.Utils$$Lambda$17/00000000F826AC00.uncaughtException(UnknownSource)[storm-client-2.3.0.jar:2.3.0] at java. lang. ThreadGroup.uncaughtException (ThreadGroup.java:B68) [7:1.8.0_2421 at java.lang. ThreadGroup.uncaughtException (ThreadGroup. java: 866) [?:1.8.0 242j at java.lang.Thread.uncaughtException(Thread.java: 1335) [7:1.8.0 242] Caused by: java.lang.RuntimeException:org.apache.storm.shade.org.apache.zookeeper.KeeperException$ConnectionLossException:KeeperErrorCode=ConnectionLossfor/storm at org.apache.storm.utils.Utils.wrapInRuntime(Utils.java:493)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.zookeeper.ClientZookeeper.existsNode(ClientZookeeper.java:147)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.zookeeper.ClientZookeeper.mkdirsImpl(ClientZookeeper.java:288)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.zookeeper.ClientZookeeper.mkdirs(ClientZookeeper.java:70)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.cluster.ZKStateStorage.(ZKStateStorage.java:65)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.cluster.ZKStateStorageFactory.mkStore(ZKStateStorageFactory.java:30)~[storm-client-2.3.0.jar:2.3.01 at org.apache.storm.cluster.ClusterUtils.mkStateStorageImpl(ClusterUtils.java:318)~[storm-client-2.3.0.jar:2.3.01 at org.apache.storm.cluster.ClusterUtils.mkStormClusterStateImpl(ClusterUtils.java:301)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.cluster.ClusterUtils.mkStormClusterState(ClusterUtils.java:286)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.daemon.supervisor. Supervisor.(Supervisor.java: 160) ~[storm-server-2.3.0.jar:2.3.0] at org.apache.storm.daemon.supervisor.Supervisor.(Supervisor.java:127)~[storm-server-2.3.0.jar:2.3.0] at org.apache.storm.daemon.supervisor.Supervisor.main(Supervisor.java:200)~[storm-server-2.3.0.jar:2.3.0] caused by: org.apache.storm.shade.org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /storm at org.apache.storm.shade.org.apache.zookeeper.KeeperException.create(KeeperException.java:102)~[storm-shaded-deps-2.3.0.jar:2.3.0] at org.apache.storm.shade.org.apache.zookeeper.KeeperException.create(KeeperException.java:54)~[storm-shaded-deps-2.3.0.jar:2.3.01 at org.apache.storm.shade.org.apache.zookeeper.ZooKeeper.exists(ZooKeeper.java:1l11)~[storm-shaded-deps-2.3.0.jar:2.3.0] at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl$3.call(ExistsBuilderImpl.java:268)~[storm-shaded-deps-2.3.0.jar:2.3.0] at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl$3.call(ExistsBuj.derImpl.java:257)~[storm-shaded-deps-2.3.0.jar:2.3.01 at org.apache.storm.shade.org.apache.curator.connection.StandardConnectionHandlingPolicy.callkäthRetry(StandardConnectionHandlingPolicy.java:64)-[storm-shaded-deps at org.apache.storm.shade.org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:100)~[storm-shaded-deps-2.3.0.jar:2.3.0] at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl.pathInForegroundStandard(ExistsBuilderImpl.java:254)~[storm-shaded-deps-2.3.0.jar:2.3 at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl.pathInForeground(ExistsBuilderImpl.java:247)~[storm-shaded-deps-2.3.0.jar:2.3.0] at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:206)~[storm-shaded-deps-2.3.0.jar:2.3.0] at org.apache.storm.shade.org.apache.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:35)~[storm-shaded-deps-2.3.0.jar:2.3.0] at org.apache.storm.zookeeper.ClientZookeeper.existsNode(ClientZookeeper.java:144)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.zookeeper.ClientZookeeper.mkdirsImpl(ClientZookeeper.java:288)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.zookeeper.ClientZookeeper.mkdirs(ClientZookeeper.java:70)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.cluster.ZKStateStorage.(ZKStateStorage.java:65)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.cluster.ZKStateStorageFactory.mkStore(ZKStateStorageFactory.java:30)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.cluster.ClusterUtils.mkStateStorageImpl(ClusterUtils.java:318)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.cluster.ClusterUtils.mkStormClusterStateImpl(ClusterUtils.java:301)~[storm-client-2.3.0.jar:2.3.0] at org.apache.storm.cluster.ClusterUtils.mkStormClusterState(ClusterUtils.java:286)-[storm-client-2.3.0.iar:2.3.01 at org.apache.storm.daemon.supervisor.Supervisor.(Supervisor.java:160)~[storm-server-2.3.0.jar:2.3.0] at org.apache.storm.daemon.supervisor.Supervisor.(Supervisor.java:127)~[storm-server-2.3.0.jar:2.3.0] at org.apache.storm.daemon. supervisor.Supervisor.main (Supervisor.java:200) ~[storm-server-2.3.0.jar:2.3.0]
1条答案
按热度按时间r55awzrz1#
zk客户端已经存在/storm节点,重新连接zk时无法连接 Storm 集群,可以登录zk客户端删除/storm节点,然后启动 Storm 集群相关流程。