Hi everybody,
I'm doing simple typologies in Storm. And so far I have one issue. I can run my topology with ether:
storm jar target/storm-counter-0.0.1-SNAPSHOT.jar TopologyMain
or
mvn exec:java -Dexec.mainClass="TopologyMain"
Both work fine, but sometimes when I run it, I get an error:
2235 [Thread-6-EventThread] INFO com.netflix.curator.framework.state.ConnectionStateManager - State change: SUSPENDED
2236 [ConnectionStateManager-0] WARN com.netflix.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered.
2238 [Thread-6-EventThread] WARN backtype.storm.cluster - Received event :disconnected::none: with disconnected Zookeeper.
3701 [Thread-6-SendThread(localhost:2000)] WARN org.apache.zookeeper.ClientCnxn - Session 0x13e18bdb0ae000b for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
Than I restart zookeeper:
sudo service zookeeper-server restart
And it works again.
I think there is something wrong, I attached zoo.cfg and storm.yaml