Hej all.
I have a problem with my zoopkeeper and I don't think that it can start.
I'm trying to run the example ExclamationTopology.java from storm-starter
and i'm running it in local mode. I recieve the right output in the
console:
16039 [Thread-30] INFO backtype.storm.daemon.task - Emitting: word
default [golda]
16040 [Thread-18] INFO backtype.storm.daemon.executor - Processing
received message source: word:9, stream: default, id: {}, [golda]
16040 [Thread-18] INFO backtype.storm.daemon.task - Emitting: exclaim1
default [golda!!!]
16040 [Thread-22] INFO backtype.storm.daemon.executor - Processing
received message source: exclaim1:3, stream: default, id: {}, [golda!!!]
16040 [Thread-22] INFO backtype.storm.daemon.task - Emitting: exclaim2
default [golda!!!!!!]
16042 [Thread-26] INFO backtype.storm.daemon.task - Emitting: word
default [jackson]
16043 [Thread-16] INFO backtype.storm.daemon.executor - Processing
received message source: word:7, stream: default, id: {}, [jackson]
16043 [Thread-16] INFO backtype.storm.daemon.task - Emitting: exclaim1
default [jackson!!!]
16043 [Thread-24] INFO backtype.storm.daemon.executor - Processing
received message source: exclaim1:2, stream: default, id: {}, [jackson!!!]
16043 [Thread-24] INFO backtype.storm.daemon.task - Emitting: exclaim2
default [jackson!!!!!!]
But in the start I recieve some errors with the socket connection in
zookeeper. On one of my computers everything runs smoothly, but on my
laptop I recieve the following errors:
1140 [main-SendThread(localhost:2000)] WARN
org.apache.zookeeper.ClientCnxn - Session 0x0 for server null, unexpected
error, closing socket connection and attempting reconnect
java.net.SocketException: Address family not supported by protocol family:
connect
at sun.nio.ch.Net.connect(Native Method)
at sun.nio.ch.SocketChannelImpl.connect(Unknown Source)
at
org.apache.zookeeper.ClientCnxn$SendThread.startConnect(ClientCnxn.java:1050)
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1077)
2093 [main-EventThread] INFO backtype.storm.zookeeper - Zookeeper state
update: :connected:none
2099 [main] INFO com.netflix.curator.framework.imps.CuratorFrameworkImpl
- Starting
2100 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN
org.apache.zookeeper.server.NIOServerCnxn - EndOfStreamException: Unable
to read additional data from client sessionid 0x13b8fbed2f80002, likely
client has closed socket
2104 [main] INFO com.netflix.curator.framework.imps.CuratorFrameworkImpl
- Starting
2110 [main-SendThread(localhost:2000)] WARN
org.apache.zookeeper.ClientCnxn - Session 0x0 for server null, unexpected
error, closing socket connection and attempting reconnect
java.net.SocketException: Address family not supported by protocol family:
connect
at sun.nio.ch.Net.connect(Native Method)
at sun.nio.ch.SocketChannelImpl.connect(Unknown Source)
at
org.apache.zookeeper.ClientCnxn$SendThread.startConnect(ClientCnxn.java:1050)
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1077)
2659 [main-EventThread] INFO backtype.storm.zookeeper - Zookeeper state
update: :connected:none
2667 [main] INFO com.netflix.curator.framework.imps.CuratorFrameworkImpl
- Starting
I run everything on windows 7 and I'm using eclipse. Where I add the jars
to the classpath (both storm.0.8.1.jar and all the jars from lib).
I hope someone can help my fix this error. What can I do ??
At last I have another question, when shuttingdown the cluster I also
recieve an exception, but I think that's okay??, the error is:
16335 [main] INFO backtype.storm.testing - Shutting down in process
zookeeper
16335 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN
org.apache.zookeeper.server.NIOServerCnxn - EndOfStreamException: Unable
to read additional data from client sessionid 0x13b8fc35a350009, likely
client has closed socket
16339 [main] INFO backtype.storm.testing - Done shutting down in process
zookeeper
16339 [main] INFO backtype.storm.testing - Deleting temporary path
C:\Users\IBM_AD~1\AppData\Local\Temp\/4a93a2ed-154b-4aee-a6a7-233be855da5b
16348 [main] INFO backtype.storm.testing - Deleting temporary path
C:\Users\IBM_AD~1\AppData\Local\Temp\/60ece752-627f-4077-9615-83549ea6889d
16421 [main] ERROR org.apache.zookeeper.server.NIOServerCnxn - Thread
Thread[main,5,main] died
java.io.IOException: Unable to delete file:
C:\Users\IBM_AD~1\AppData\Local\Temp\60ece752-627f-4077-9615-83549ea6889d\version-2\log.1
at org.apache.commons.io.FileUtils.forceDelete(FileUtils.java:1390)
at org.apache.commons.io.FileUtils.cleanDirectory(FileUtils.java:1044)
at org.apache.commons.io.FileUtils.deleteDirectory(FileUtils.java:977)
at org.apache.commons.io.FileUtils.forceDelete(FileUtils.java:1381)
at org.apache.commons.io.FileUtils.cleanDirectory(FileUtils.java:1044)
at org.apache.commons.io.FileUtils.deleteDirectory(FileUtils.java:977)
at org.apache.commons.io.FileUtils.forceDelete(FileUtils.java:1381)
at backtype.storm.util$rmr.invoke(util.clj:413)
at backtype.storm.testing$kill_local_storm_cluster.invoke(testing.clj:163)
at backtype.storm.LocalCluster$_shutdown.invoke(LocalCluster.clj:25)
at backtype.storm.LocalCluster.shutdown(Unknown Source)
at storm.starter.ExclamationTopology.main(ExclamationTopology.java:67)
Thanks in advance.
---
Best regards from Jesper Marrup..
