Connection отказался ошибка в Буре

Question

Я новичок в Буре .. Я stucked с ниже ошибками

java.net.ConnectException: Connection refused 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599) 
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1119) 
1178482 [Thread-11-SendThread(localhost:2000)] WARN org.apache.zookeeper.ClientCnxn - Session 0x1417cd58578000b for server null, unexpected error, closing socket connection and attempting reconnect 

Иногда моя топология работает нормально, но когда я попробовал еще раз я получил выше error.Searched много в гугле, но могу nt найти любую подсказку. Я бегу мой топологии в локальном кластере .. пожалуйста, предложить некоторые решения

Вы можете найти больше журналов ниже: -

2595 [Thread-11-EventThread] INFO com.netflix.curator.framework.state.ConnectionStateManager - State change: SUSPENDED 
2596 [Thread-11-EventThread] WARN backtype.storm.cluster - Received event :disconnected::none: with disconnected Zookeeper. 
2596 [ConnectionStateManager-0] WARN com.netflix.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered. 
3592 [Thread-11-SendThread(localhost:2000)] WARN org.apache.zookeeper.ClientCnxn - Session 0x1417e6596c7000b for server null, unexpected error, closing socket connection and attempting reconnect 
java.net.ConnectException: Connection refused 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599) 
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1119) 
3895 [Thread-11-SendThread(localhost:2000)] WARN org.apache.zookeeper.ClientCnxn - Session 0x1417e6596c7000b for server null, unexpected error, closing socket connection and attempting reconnect 
org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss 
    at org.apache.zookeeper.KeeperException.create(KeeperException.java:90) 
    at com.netflix.curator.framework.imps.CuratorFrameworkImpl.processBackgroundOperation(CuratorFrameworkImpl.java:380) 
    at com.netflix.curator.framework.imps.BackgroundSyncImpl$1.processResult(BackgroundSyncImpl.java:49) 
    at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:617) 
    at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:506) 

Вы можете найти больше журнала: -

java.net.ConnectException: Connection refused 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:599) 
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1119) 
50454 [Thread-15] ERROR com.netflix.curator.ConnectionState - Connection timed out 
org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss 
    at com.netflix.curator.ConnectionState.getZooKeeper(ConnectionState.java:72) 
    at com.netflix.curator.CuratorZookeeperClient.getZooKeeper(CuratorZookeeperClient.java:74) 
    at com.netflix.curator.framework.imps.CuratorFrameworkImpl.getZooKeeper(CuratorFrameworkImpl.java:353) 
    at com.netflix.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:149) 
    at com.netflix.curator.framework.imps.ExistsBuilderImpl$2.call(ExistsBuilderImpl.java:138) 
    at com.netflix.curator.RetryLoop.callWithRetry(RetryLoop.java:85) 
    at com.netflix.curator.framework.imps.ExistsBuilderImpl.pathInForeground(ExistsBuilderImpl.java:134) 
    at com.netflix.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:125) 
    at com.netflix.curator.framework.imps.ExistsBuilderImpl.forPath(ExistsBuilderImpl.java:34) 
    at backtype.storm.zookeeper$exists_node_QMARK_.invoke(zookeeper.clj:78) 
    at backtype.storm.zookeeper$exists.invoke(zookeeper.clj:117) 
    at backtype.storm.cluster$mk_distributed_cluster_state$reify__1996.set_data(cluster.clj:70) 
    at backtype.storm.cluster$mk_storm_cluster_state$reify__2415.worker_heartbeat_BANG_(cluster.clj:276) 
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) 
    at java.lang.reflect.Method.invoke(Method.java:597) 
    at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93) 
    at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28) 
    at backtype.storm.daemon.worker$do_executor_heartbeats.doInvoke(worker.clj:35) 
    at clojure.lang.RestFn.invoke(RestFn.java:439) 
    at backtype.storm.daemon.worker$fn__4348$exec_fn__1228__auto____4349$fn__4352.invoke(worker.clj:346) 
    at backtype.storm.timer$schedule_recurring$this__1776.invoke(timer.clj:69) 
    at backtype.storm.timer$mk_timer$fn__1759$fn__1760.invoke(timer.clj:33) 
    at backtype.storm.timer$mk_timer$fn__1759.invoke(timer.clj:26) 
    at clojure.lang.AFn.run(AFn.java:24) 
    at java.lang.Thread.run(Thread.java:680) 

Answer 1

Я просто сталкивался с этой проблемой тоже. Моя проблема, время работы устанавливается слишком short.The зоопарка не хватает времени, чтобы закрыть properly.Look в коде ниже:

builder.createTopology()); 

    try { 
     Thread.sleep(20000); 
    } catch (InterruptedException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 
    cluster.shutdown(); 
} 

Вы должны установить достаточно времени до cluster.shutdown() была вызвана , Сначала я устанавливаю Thread.sleep (1000), тогда та же проблема возникла как ваша. После того, как я изменил время, эта проблема никогда не появлялась снова.