You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Dharmarajan Rajendran <dh...@trimble.com> on 2018/06/25 11:09:28 UTC
NimbusLeaderNotFoundException

Hello storm users,

We are using storm cluster (version 1.2.1) in our production environment
hosted in AWS.
We are observing an odd behavior with storm. we have a storm cluster with 1
nimbus and 3 supervisors. The topologies are running fine but often we are
seeing the below errors in nimbus and supervisor logs. The supervisor
process stopped on its own and we are restarting it to bring the service up
and running. sometimes it failed to start and we need to clear the cache
located at storm.local.dir
We have verified the connectivity between nimbus and supervisors and with
zookeeper instances. All are looking good. but unable to find out the root
cause of this issue.
We are running 3 node zookeeper (version 3.4.9) cluster in a separate
machines.

Did anyone came across this situation. Your help is much appreciated.

*nimbus.log*

2018-04-08 04:51:03.000 o.a.s.s.o.a.z.ClientCnxn
main-SendThread(zookeeper-host:2181) [INFO] Opening socket connection to
server zookeeper-host/xx.xx.xx.xx:2181. Will not attempt to authenticate
using SASL (unknown error)
2018-04-08 04:51:03.001 o.a.s.s.o.a.z.ClientCnxn
main-SendThread(zookeeper-host:2181) [WARN] Session 0x0 for server null,
unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
~[?:1.8.0_162]
        at sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)
~[?:1.8.0_162]
        at
org.apache.storm.shade.org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081)
~[storm-core-1.2.1.jar:1.2.1]
2018-04-08 04:51:03.101 o.a.s.u.StormBoundedExponentialBackoffRetry timer
[WARN] WILL SLEEP FOR 1004ms (NOT MAX)
2018-04-08 04:51:03.268 o.a.s.s.o.a.z.ClientCnxn
main-SendThread(zookeeper-host:2181) [INFO] Opening socket connection to
server zookeeper-host/xx.xx.xx.xx:2181. Will not attempt to authenticate
using SASL (unknown error)
2018-04-08 04:51:03.269 o.a.s.s.o.a.z.ClientCnxn
main-SendThread(zookeeper-host:2181) [INFO] Socket connection established
to zookeeper-host/xx.xx.xx.xx:2181, initiating session
2018-04-08 04:51:03.270 o.a.s.s.o.a.z.ClientCnxn
main-SendThread(zookeeper-host:2181) [INFO] Unable to read additional data
from server sessionid 0x0, likely server has closed socket, closing socket
connection and attempting reconnect
2018-04-08 04:51:03.683 o.a.s.s.o.a.z.ClientCnxn
main-SendThread(zookeeper-host:2181) [INFO] Opening socket connection to
server zookeeper-host/xx.xx.xx.xx:2181. Will not attempt to authenticate
using SASL (unknown error)
2018-04-08 04:51:03.684 o.a.s.s.o.a.z.ClientCnxn
main-SendThread(zookeeper-host:2181) [WARN] Session 0x0 for server null,
unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
~[?:1.8.0_162]
        at sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)
~[?:1.8.0_162]
        at
org.apache.storm.shade.org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081)
~[storm-core-1.2.1.jar:1.2.1]
2018-04-08 04:51:03.854 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl
Curator-Framework-0 [ERROR] Background operation retry gave up
org.apache.storm.shade.org.apache.zookeeper.KeeperException$ConnectionLossException:
KeeperErrorCode = ConnectionLoss
        at
org.apache.storm.shade.org.apache.zookeeper.KeeperException.create(KeeperException.java:99)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.CuratorFrameworkImpl.checkBackgroundRetry(CuratorFrameworkImpl.java:831)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.CuratorFrameworkImpl.performBackgroundOperation(CuratorFrameworkImpl.java:960)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.CuratorFrameworkImpl.backgroundOperationsLoop(CuratorFrameworkImpl.java:912)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.CuratorFrameworkImpl.access$300(CuratorFrameworkImpl.java:70)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.CuratorFrameworkImpl$4.call(CuratorFrameworkImpl.java:316)
~[storm-core-1.2.1.jar:1.2.1]
        at java.util.concurrent.FutureTask.run(Unknown Source)
~[?:1.8.0_162]
        at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(Unknown
Source) ~[?:1.8.0_162]
        at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown
Source) ~[?:1.8.0_162]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown
Source) [?:1.8.0_162]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source) [?:1.8.0_162]
        at java.lang.Thread.run(Unknown Source) [?:1.8.0_162]
2018-04-08 04:51:03.855 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl
Curator-Framework-0 [ERROR] Background retry gave up
org.apache.storm.shade.org.apache.curator.CuratorConnectionLossException:
KeeperErrorCode = ConnectionLoss
        at
org.apache.storm.shade.org.apache.curator.framework.imps.CuratorFrameworkImpl.performBackgroundOperation(CuratorFrameworkImpl.java:941)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.CuratorFrameworkImpl.backgroundOperationsLoop(CuratorFrameworkImpl.java:912)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.CuratorFrameworkImpl.access$300(CuratorFrameworkImpl.java:70)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.CuratorFrameworkImpl$4.call(CuratorFrameworkImpl.java:316)
~[storm-core-1.2.1.jar:1.2.1]
        at java.util.concurrent.FutureTask.run(Unknown Source)
~[?:1.8.0_162]
        at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(Unknown
Source) ~[?:1.8.0_162]
        at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown
Source) ~[?:1.8.0_162]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown
Source) [?:1.8.0_162]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source) [?:1.8.0_162]
        at java.lang.Thread.run(Unknown Source) [?:1.8.0_162]


2018-04-08 04:51:07.955 o.a.s.d.nimbus timer [ERROR] Error when processing
event
java.lang.RuntimeException:
org.apache.storm.shade.org.apache.zookeeper.KeeperException$ConnectionLossException:
KeeperErrorCode = ConnectionLoss for /blobstore
        at org.apache.storm.util$wrap_in_runtime.invoke(util.clj:54)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.zookeeper$get_children.invoke(zookeeper.clj:190)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.cluster_state.zookeeper_state_factory$_mkState$reify__12463.get_children(zookeeper_state_factory.clj:133)
~[storm-core-1.2.1.jar:1.2.1]
        at sun.reflect.GeneratedMethodAccessor23.invoke(Unknown Source)
~[?:?]
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
~[?:1.8.0_162]
        at java.lang.reflect.Method.invoke(Unknown Source) ~[?:1.8.0_162]
        at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
~[clojure-1.7.0.jar:?]
        at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
~[clojure-1.7.0.jar:?]
        at
org.apache.storm.cluster$mk_storm_cluster_state$reify__4385.blobstore(cluster.clj:338)
~[storm-core-1.2.1.jar:1.2.1]
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_162]
        at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
~[?:1.8.0_162]
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
~[?:1.8.0_162]
        at java.lang.reflect.Method.invoke(Unknown Source) ~[?:1.8.0_162]
        at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
~[clojure-1.7.0.jar:?]
        at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
~[clojure-1.7.0.jar:?]
        at org.apache.storm.daemon.nimbus$fn__10624.invoke(nimbus.clj:1490)
~[storm-core-1.2.1.jar:1.2.1]
        at clojure.lang.MultiFn.invoke(MultiFn.java:233)
~[clojure-1.7.0.jar:?]
        at
org.apache.storm.daemon.nimbus$fn__11026$exec_fn__1369__auto____11027$fn__11042.invoke(nimbus.clj:2509)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.timer$schedule_recurring$this__1721.invoke(timer.clj:105)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.timer$mk_timer$fn__1704$fn__1705.invoke(timer.clj:50)
~[storm-core-1.2.1.jar:1.2.1]
        at org.apache.storm.timer$mk_timer$fn__1704.invoke(timer.clj:42)
~[storm-core-1.2.1.jar:1.2.1]
        at clojure.lang.AFn.run(AFn.java:22) ~[clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Unknown Source) [?:1.8.0_162]
Caused by:
org.apache.storm.shade.org.apache.zookeeper.KeeperException$ConnectionLossException:
KeeperErrorCode = ConnectionLoss for /blobstore
        at
org.apache.storm.shade.org.apache.zookeeper.KeeperException.create(KeeperException.java:99)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.zookeeper.KeeperException.create(KeeperException.java:51)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1590)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1625)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.GetChildrenBuilderImpl$3.call(GetChildrenBuilderImpl.java:238)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.GetChildrenBuilderImpl$3.call(GetChildrenBuilderImpl.java:231)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.connection.StandardConnectionHandlingPolicy.callWithRetry(StandardConnectionHandlingPolicy.java:64)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:100)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.GetChildrenBuilderImpl.pathInForeground(GetChildrenBuilderImpl.java:228)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.shade.org.apache.curator.framework.imps.GetChildrenBuilderImpl.forPath(GetChildrenBuilderImpl.java:219)
~[storm-core-1.2.1.jar:1.2.1]
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_162]
        at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
~[?:1.8.0_162]
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
~[?:1.8.0_162]
        at java.lang.reflect.Method.invoke(Unknown Source) ~[?:1.8.0_162]
        at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
~[clojure-1.7.0.jar:?]
        at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
~[clojure-1.7.0.jar:?]
        at
org.apache.storm.zookeeper$get_children.invoke(zookeeper.clj:188)
~[storm-core-1.2.1.jar:1.2.1]
        ... 21 more


*supervisor.log*


2018-06-22 06:35:23.308 o.a.s.d.s.Slot SLOT_6700 [ERROR] Error when
processing event
java.util.concurrent.ExecutionException:
org.apache.storm.utils.NimbusLeaderNotFoundException: Could not find leader
nimbus from seed hosts [nimbus-host]. Did you specify a valid list of
nimbus hosts for config nimbus.seeds?
        at java.util.concurrent.FutureTask.report(Unknown Source)
~[?:1.8.0_162]
        at java.util.concurrent.FutureTask.get(Unknown Source)
~[?:1.8.0_162]
        at
org.apache.storm.localizer.LocalDownloadedResource$NoCancelFuture.get(LocalDownloadedResource.java:63)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.daemon.supervisor.Slot.handleWaitingForBasicLocalization(Slot.java:413)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.daemon.supervisor.Slot.stateMachineStep(Slot.java:273)
~[storm-core-1.2.1.jar:1.2.1]
        at org.apache.storm.daemon.supervisor.Slot.run(Slot.java:752)
[storm-core-1.2.1.jar:1.2.1]
Caused by: org.apache.storm.utils.NimbusLeaderNotFoundException: Could not
find leader nimbus from seed hosts [nimbus-host]. Did you specify a valid
list of nimbus hosts for config nimbus.seeds?
        at
org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:120)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:66)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:58)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.blobstore.NimbusBlobStore.prepare(NimbusBlobStore.java:268)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.utils.Utils.getClientBlobStoreForSupervisor(Utils.java:538)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.downloadBaseBlobs(AsyncLocalizer.java:121)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.call(AsyncLocalizer.java:148)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.call(AsyncLocalizer.java:101)
~[storm-core-1.2.1.jar:1.2.1]
        at java.util.concurrent.FutureTask.run(Unknown Source)
~[?:1.8.0_162]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown
Source) ~[?:1.8.0_162]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source) ~[?:1.8.0_162]
        at java.lang.Thread.run(Unknown Source) ~[?:1.8.0_162]
2018-06-22 06:35:23.309 o.a.s.u.Utils SLOT_6700 [ERROR] Halting process:
Error when processing an event
java.lang.RuntimeException: Halting process: Error when processing an event
        at org.apache.storm.utils.Utils.exitProcess(Utils.java:1777)
[storm-core-1.2.1.jar:1.2.1]
        at org.apache.storm.daemon.supervisor.Slot.run(Slot.java:796)
[storm-core-1.2.1.jar:1.2.1]
2018-06-22 06:35:23.311 o.a.s.d.s.Supervisor Thread-5 [INFO] Shutting down
supervisor 5ed77b51-ebf4-4424-ade0-9797b8fd0156
2018-06-22 06:35:23.310 o.a.s.u.NimbusClient Async Localizer [WARN]
Ignoring exception while trying to get leader nimbus info from nimbus-host.
will retry with a different seed host.
org.apache.storm.thrift.transport.TTransportException: null
        at
org.apache.storm.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.thrift.transport.TTransport.readAll(TTransport.java:86)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.thrift.transport.TTransport.readAll(TTransport.java:86)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.thrift.TServiceClient.receiveBase(TServiceClient.java:77)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.generated.Nimbus$Client.recv_getLeader(Nimbus.java:1193)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.generated.Nimbus$Client.getLeader(Nimbus.java:1181)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:93)
[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:66)
[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:58)
[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.blobstore.NimbusBlobStore.prepare(NimbusBlobStore.java:268)
[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.utils.Utils.getClientBlobStoreForSupervisor(Utils.java:538)
[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.downloadBaseBlobs(AsyncLocalizer.java:121)
[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.call(AsyncLocalizer.java:148)
[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.call(AsyncLocalizer.java:101)
[storm-core-1.2.1.jar:1.2.1]
        at java.util.concurrent.FutureTask.run(Unknown Source) [?:1.8.0_162]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown
Source) [?:1.8.0_162]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source) [?:1.8.0_162]
        at java.lang.Thread.run(Unknown Source) [?:1.8.0_162]
2018-06-22 06:35:23.311 o.a.s.l.AsyncLocalizer Async Localizer [WARN]
Failed to download basic resources for topology-id
oculusEventsProcessor-39-1524078710
2018-06-22 06:35:23.311 o.a.s.d.s.AdvancedFSOps Async Localizer [INFO]
Deleting path /app/storm/supervisor/tmp/4443e7ac-ac3e-4a11-a774-7b67725707f4
2018-06-22 06:35:23.312 o.a.s.d.s.AdvancedFSOps Async Localizer [INFO]
Deleting path
/app/storm/supervisor/stormdist/oculusEventsProcessor-39-1524078710
2018-06-22 06:35:23.312 o.a.s.l.AsyncLocalizer Async Localizer [WARN]
Caught Exception While Downloading (rethrowing)...
org.apache.storm.utils.NimbusLeaderNotFoundException: Could not find leader
nimbus from seed hosts [nimbus-host]. Did you specify a valid list of
nimbus hosts for config nimbus.seeds?
        at
org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:120)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:66)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:58)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.blobstore.NimbusBlobStore.prepare(NimbusBlobStore.java:268)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.utils.Utils.getClientBlobStoreForSupervisor(Utils.java:538)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.downloadBaseBlobs(AsyncLocalizer.java:121)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.call(AsyncLocalizer.java:148)
[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.call(AsyncLocalizer.java:101)
[storm-core-1.2.1.jar:1.2.1]
        at java.util.concurrent.FutureTask.run(Unknown Source) [?:1.8.0_162]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown
Source) [?:1.8.0_162]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source) [?:1.8.0_162]
        at java.lang.Thread.run(Unknown Source) [?:1.8.0_162]
2018-06-22 06:35:23.312 o.a.s.d.s.ReadClusterState Thread-4 [ERROR] Failed
to Sync Supervisor
java.lang.RuntimeException: java.lang.InterruptedException
        at org.apache.storm.utils.Utils.wrapInRuntime(Utils.java:1535)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.zookeeper.Zookeeper.existsNode(Zookeeper.java:167)
~[storm-core-1.2.1.jar:1.2.1]
        at
org.apache.storm.zookeeper.Zookeeper.getVersion(Zookeeper.java:246)
~[storm-core-12018-06-22 06:35:38.626 o.a.s.s.o.a.c.u.Compatibility main
[INFO] Running in ZooKeeper 3.4.x compatibility mode


Thanks