图文精华

About云»专题 › 交流区 › 技术交流 › Storm › 单击环境运行Storm程序报错
分享

单击环境运行Storm程序报错

Joker 发表于 2014-11-25 14:49:43 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 5 90196
在Eclipse中运行Storm程序，第一次是完全成功的，但是在运行第二次

  1. 1781 [main] INFO  backtype.storm.zookeeper - Starting inprocess zookeeper at port 2000 and dir C:\Users\base\AppData\Local\Temp\f63a50c6-fd7d-4cc5-8563-256cbe967dac

  2. 1954 [main] INFO  backtype.storm.daemon.nimbus - Starting Nimbus with conf {"dev.zookeeper.path" "/tmp/dev-storm-zookeeper", "topology.tick.tuple.freq.secs" nil, "topology.builtin.metrics.bucket.size.secs" 60, "topology.fall.back.on.java.serialization" true, "topology.max.error.report.per.interval" 5, "zmq.linger.millis" 0, "topology.skip.missing.kryo.registrations" true, "storm.messaging.netty.client_worker_threads" 1, "ui.childopts" "-Xmx768m", "storm.zookeeper.session.timeout" 20000, "nimbus.reassign" true, "topology.trident.batch.emit.interval.millis" 50, "storm.messaging.netty.flush.check.interval.ms" 10, "nimbus.monitor.freq.secs" 10, "logviewer.childopts" "-Xmx128m", "java.library.path" "/usr/local/lib:/opt/local/lib:/usr/lib", "topology.executor.send.buffer.size" 1024, "storm.local.dir" "C:\\Users\\base\\AppData\\Local\\Temp\\7684ea21-4d8d-4923-9f88-dd64b24186e1", "storm.messaging.netty.buffer_size" 5242880, "supervisor.worker.start.timeout.secs" 120, "topology.enable.message.timeouts" true, "nimbus.cleanup.inbox.freq.secs" 600, "nimbus.inbox.jar.expiration.secs" 3600, "drpc.worker.threads" 64, "topology.worker.shared.thread.pool.size" 4, "nimbus.host" "localhost", "storm.messaging.netty.min_wait_ms" 100, "storm.zookeeper.port" 2000, "transactional.zookeeper.port" nil, "topology.executor.receive.buffer.size" 1024, "transactional.zookeeper.servers" nil, "storm.zookeeper.root" "/storm", "storm.zookeeper.retry.intervalceiling.millis" 30000, "supervisor.enable" true, "storm.messaging.netty.server_worker_threads" 1, "storm.zookeeper.servers" ["localhost"], "transactional.zookeeper.root" "/transactional", "topology.acker.executors" nil, "topology.transfer.buffer.size" 1024, "topology.worker.childopts" nil, "drpc.queue.size" 128, "worker.childopts" "-Xmx768m", "supervisor.heartbeat.frequency.secs" 5, "topology.error.throttle.interval.secs" 10, "zmq.hwm" 0, "drpc.port" 3772, "supervisor.monitor.frequency.secs" 3, "drpc.childopts" "-Xmx768m", "topology.receiver.buffer.size" 8, "task.heartbeat.frequency.secs" 3, "topology.tasks" nil, "storm.messaging.netty.max_retries" 30, "topology.spout.wait.strategy" "backtype.storm.spout.SleepSpoutWaitStrategy", "nimbus.thrift.max_buffer_size" 1048576, "topology.max.spout.pending" nil, "storm.zookeeper.retry.interval" 1000, "topology.sleep.spout.wait.strategy.time.ms" 1, "nimbus.topology.validator" "backtype.storm.nimbus.DefaultTopologyValidator", "supervisor.slots.ports" [6700 6701 6702 6703], "topology.debug" false, "nimbus.task.launch.secs" 120, "nimbus.supervisor.timeout.secs" 60, "topology.message.timeout.secs" 30, "task.refresh.poll.secs" 10, "topology.workers" 1, "supervisor.childopts" "-Xmx256m", "nimbus.thrift.port" 6627, "topology.stats.sample.rate" 0.05, "worker.heartbeat.frequency.secs" 1, "topology.tuple.serializer" "backtype.storm.serialization.types.ListDelegateSerializer", "topology.disruptor.wait.strategy" "com.lmax.disruptor.BlockingWaitStrategy", "topology.multilang.serializer" "backtype.storm.multilang.JsonSerializer", "nimbus.task.timeout.secs" 30, "storm.zookeeper.connection.timeout" 15000, "topology.kryo.factory" "backtype.storm.serialization.DefaultKryoFactory", "drpc.invocations.port" 3773, "logviewer.port" 8000, "zmq.threads" 1, "storm.zookeeper.retry.times" 5, "topology.worker.receiver.thread.count" 1, "storm.thrift.transport" "backtype.storm.security.auth.SimpleTransportPlugin", "topology.state.synchronization.timeout.secs" 60, "supervisor.worker.timeout.secs" 30, "nimbus.file.copy.expiration.secs" 600, "storm.messaging.transport" "backtype.storm.messaging.netty.Context", "logviewer.appender.name" "A1", "storm.messaging.netty.max_wait_ms" 1000, "drpc.request.timeout.secs" 600, "storm.local.mode.zmq" false, "ui.port" 8080, "nimbus.childopts" "-Xmx1024m", "storm.cluster.mode" "local", "topology.max.task.parallelism" nil, "storm.messaging.netty.transfer.batch.size" 262144}

  3. 1954 [main] INFO  backtype.storm.daemon.nimbus - Using default scheduler

  4. 2016 [main] INFO  org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting

  5. 2095 [main-EventThread] INFO  org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED

  6. 2095 [ConnectionStateManager-0] WARN  org.apache.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered.

  7. 2095 [main-EventThread] INFO  backtype.storm.zookeeper - Zookeeper state update: :connected:none

  8. 3173 [main] INFO  org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting

  9. 3173 [main-EventThread] INFO  org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED

  10. 3173 [ConnectionStateManager-0] WARN  org.apache.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered.

  11. 3205 [main] INFO  org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting

  12. 3205 [main-EventThread] INFO  org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED

  13. 3205 [ConnectionStateManager-0] WARN  org.apache.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered.

  14. 3205 [main-EventThread] INFO  backtype.storm.zookeeper - Zookeeper state update: :connected:none

  15. 3205 [main] INFO  org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting

  16. 3205 [main] INFO  org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting

  17. 3221 [main-EventThread] INFO  org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED

  18. 3221 [ConnectionStateManager-0] WARN  org.apache.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered.

  19. 3346 [main-EventThread] INFO  org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED

  20. 3346 [main-EventThread] INFO  backtype.storm.zookeeper - Zookeeper state update: :connected:none

  21. 3346 [ConnectionStateManager-0] WARN  org.apache.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered.

  22. 3346 [main] INFO  org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting

  23. 3346 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN  org.apache.zookeeper.server.NIOServerCnxn - caught end of stream exception

  24. org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x149e5b3f1490004, likely client has closed socket

  25.         at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:220) ~[zookeeper-3.4.5.jar:3.4.5-1392090]

  26.         at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [zookeeper-3.4.5.jar:3.4.5-1392090]

  27.         at java.lang.Thread.run(Unknown Source) [na:1.8.0_05]

  28. 3361 [main-EventThread] INFO  org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED

  29. 3361 [ConnectionStateManager-0] WARN  org.apache.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered.

  30. 3361 [main] INFO  backtype.storm.daemon.supervisor - Starting Supervisor with conf {"dev.zookeeper.path" "/tmp/dev-storm-zookeeper", "topology.tick.tuple.freq.secs" nil, "topology.builtin.metrics.bucket.size.secs" 60, "topology.fall.back.on.java.serialization" true, "topology.max.error.report.per.interval" 5, "zmq.linger.millis" 0, "topology.skip.missing.kryo.registrations" true, "storm.messaging.netty.client_worker_threads" 1, "ui.childopts" "-Xmx768m", "storm.zookeeper.session.timeout" 20000, "nimbus.reassign" true, "topology.trident.batch.emit.interval.millis" 50, "storm.messaging.netty.flush.check.interval.ms" 10, "nimbus.monitor.freq.secs" 10, "logviewer.childopts" "-Xmx128m", "java.library.path" "/usr/local/lib:/opt/local/lib:/usr/lib", "topology.executor.send.buffer.size" 1024, "storm.local.dir" "C:\\Users\\base\\AppData\\Local\\Temp\\d96f0d72-7f06-4f41-9856-befc12c55ce2", "storm.messaging.netty.buffer_size" 5242880, "supervisor.worker.start.timeout.secs" 120, "topology.enable.message.timeouts" true, "nimbus.cleanup.inbox.freq.secs" 600, "nimbus.inbox.jar.expiration.secs" 3600, "drpc.worker.threads" 64, "topology.worker.shared.thread.pool.size" 4, "nimbus.host" "localhost", "storm.messaging.netty.min_wait_ms" 100, "storm.zookeeper.port" 2000, "transactional.zookeeper.port" nil, "topology.executor.receive.buffer.size" 1024, "transactional.zookeeper.servers" nil, "storm.zookeeper.root" "/storm", "storm.zookeeper.retry.intervalceiling.millis" 30000, "supervisor.enable" true, "storm.messaging.netty.server_worker_threads" 1, "storm.zookeeper.servers" ["localhost"], "transactional.zookeeper.root" "/transactional", "topology.acker.executors" nil, "topology.transfer.buffer.size" 1024, "topology.worker.childopts" nil, "drpc.queue.size" 128, "worker.childopts" "-Xmx768m", "supervisor.heartbeat.frequency.secs" 5, "topology.error.throttle.interval.secs" 10, "zmq.hwm" 0, "drpc.port" 3772, "supervisor.monitor.frequency.secs" 3, "drpc.childopts" "-Xmx768m", "topology.receiver.buffer.size" 8, "task.heartbeat.frequency.secs" 3, "topology.tasks" nil, "storm.messaging.netty.max_retries" 30, "topology.spout.wait.strategy" "backtype.storm.spout.SleepSpoutWaitStrategy", "nimbus.thrift.max_buffer_size" 1048576, "topology.max.spout.pending" nil, "storm.zookeeper.retry.interval" 1000, "topology.sleep.spout.wait.strategy.time.ms" 1, "nimbus.topology.validator" "backtype.storm.nimbus.DefaultTopologyValidator", "supervisor.slots.ports" (1024 1025 1026), "topology.debug" false, "nimbus.task.launch.secs" 120, "nimbus.supervisor.timeout.secs" 60, "topology.message.timeout.secs" 30, "task.refresh.poll.secs" 10, "topology.workers" 1, "supervisor.childopts" "-Xmx256m", "nimbus.thrift.port" 6627, "topology.stats.sample.rate" 0.05, "worker.heartbeat.frequency.secs" 1, "topology.tuple.serializer" "backtype.storm.serialization.types.ListDelegateSerializer", "topology.disruptor.wait.strategy" "com.lmax.disruptor.BlockingWaitStrategy", "topology.multilang.serializer" "backtype.storm.multilang.JsonSerializer", "nimbus.task.timeout.secs" 30, "storm.zookeeper.connection.timeout" 15000, "topology.kryo.factory" "backtype.storm.serialization.DefaultKryoFactory", "drpc.invocations.port" 3773, "logviewer.port" 8000, "zmq.threads" 1, "storm.zookeeper.retry.times" 5, "topology.worker.receiver.thread.count" 1, "storm.thrift.transport" "backtype.storm.security.auth.SimpleTransportPlugin", "topology.state.synchronization.timeout.secs" 60, "supervisor.worker.timeout.secs" 30, "nimbus.file.copy.expiration.secs" 600, "storm.messaging.transport" "backtype.storm.messaging.netty.Context", "logviewer.appender.name" "A1", "storm.messaging.netty.max_wait_ms" 1000, "drpc.request.timeout.secs" 600, "storm.local.mode.zmq" false, "ui.port" 8080, "nimbus.childopts" "-Xmx1024m", "storm.cluster.mode" "local", "topology.max.task.parallelism" nil, "storm.messaging.netty.transfer.batch.size" 262144}

  31. 3377 [main] INFO  org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting

  32. 3393 [main-EventThread] INFO  org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED

  33. 3393 [ConnectionStateManager-0] WARN  org.apache.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered.

  34. 3393 [main-EventThread] INFO  backtype.storm.zookeeper - Zookeeper state update: :connected:none

  35. 3393 [main] INFO  org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting

  36. 3408 [main-EventThread] INFO  org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED

  37. 3408 [ConnectionStateManager-0] WARN  org.apache.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered.

  38. 3439 [main] INFO  backtype.storm.daemon.supervisor - Starting supervisor with id 8b5183d5-b921-43d0-b136-50ca470dc15f at host Joker

  39. 3439 [main] INFO  backtype.storm.daemon.supervisor - Starting Supervisor with conf {"dev.zookeeper.path" "/tmp/dev-storm-zookeeper", "topology.tick.tuple.freq.secs" nil, "topology.builtin.metrics.bucket.size.secs" 60, "topology.fall.back.on.java.serialization" true, "topology.max.error.report.per.interval" 5, "zmq.linger.millis" 0, "topology.skip.missing.kryo.registrations" true, "storm.messaging.netty.client_worker_threads" 1, "ui.childopts" "-Xmx768m", "storm.zookeeper.session.timeout" 20000, "nimbus.reassign" true, "topology.trident.batch.emit.interval.millis" 50, "storm.messaging.netty.flush.check.interval.ms" 10, "nimbus.monitor.freq.secs" 10, "logviewer.childopts" "-Xmx128m", "java.library.path" "/usr/local/lib:/opt/local/lib:/usr/lib", "topology.executor.send.buffer.size" 1024, "storm.local.dir" "C:\\Users\\base\\AppData\\Local\\Temp\\5cd74d33-4602-4360-bfe7-ec7dc4e3423b", "storm.messaging.netty.buffer_size" 5242880, "supervisor.worker.start.timeout.secs" 120, "topology.enable.message.timeouts" true, "nimbus.cleanup.inbox.freq.secs" 600, "nimbus.inbox.jar.expiration.secs" 3600, "drpc.worker.threads" 64, "topology.worker.shared.thread.pool.size" 4, "nimbus.host" "localhost", "storm.messaging.netty.min_wait_ms" 100, "storm.zookeeper.port" 2000, "transactional.zookeeper.port" nil, "topology.executor.receive.buffer.size" 1024, "transactional.zookeeper.servers" nil, "storm.zookeeper.root" "/storm", "storm.zookeeper.retry.intervalceiling.millis" 30000, "supervisor.enable" true, "storm.messaging.netty.server_worker_threads" 1, "storm.zookeeper.servers" ["localhost"], "transactional.zookeeper.root" "/transactional", "topology.acker.executors" nil, "topology.transfer.buffer.size" 1024, "topology.worker.childopts" nil, "drpc.queue.size" 128, "worker.childopts" "-Xmx768m", "supervisor.heartbeat.frequency.secs" 5, "topology.error.throttle.interval.secs" 10, "zmq.hwm" 0, "drpc.port" 3772, "supervisor.monitor.frequency.secs" 3, "drpc.childopts" "-Xmx768m", "topology.receiver.buffer.size" 8, "task.heartbeat.frequency.secs" 3, "topology.tasks" nil, "storm.messaging.netty.max_retries" 30, "topology.spout.wait.strategy" "backtype.storm.spout.SleepSpoutWaitStrategy", "nimbus.thrift.max_buffer_size" 1048576, "topology.max.spout.pending" nil, "storm.zookeeper.retry.interval" 1000, "topology.sleep.spout.wait.strategy.time.ms" 1, "nimbus.topology.validator" "backtype.storm.nimbus.DefaultTopologyValidator", "supervisor.slots.ports" (1027 1028 1029), "topology.debug" false, "nimbus.task.launch.secs" 120, "nimbus.supervisor.timeout.secs" 60, "topology.message.timeout.secs" 30, "task.refresh.poll.secs" 10, "topology.workers" 1, "supervisor.childopts" "-Xmx256m", "nimbus.thrift.port" 6627, "topology.stats.sample.rate" 0.05, "worker.heartbeat.frequency.secs" 1, "topology.tuple.serializer" "backtype.storm.serialization.types.ListDelegateSerializer", "topology.disruptor.wait.strategy" "com.lmax.disruptor.BlockingWaitStrategy", "topology.multilang.serializer" "backtype.storm.multilang.JsonSerializer", "nimbus.task.timeout.secs" 30, "storm.zookeeper.connection.timeout" 15000, "topology.kryo.factory" "backtype.storm.serialization.DefaultKryoFactory", "drpc.invocations.port" 3773, "logviewer.port" 8000, "zmq.threads" 1, "storm.zookeeper.retry.times" 5, "topology.worker.receiver.thread.count" 1, "storm.thrift.transport" "backtype.storm.security.auth.SimpleTransportPlugin", "topology.state.synchronization.timeout.secs" 60, "supervisor.worker.timeout.secs" 30, "nimbus.file.copy.expiration.secs" 600, "storm.messaging.transport" "backtype.storm.messaging.netty.Context", "logviewer.appender.name" "A1", "storm.messaging.netty.max_wait_ms" 1000, "drpc.request.timeout.secs" 600, "storm.local.mode.zmq" false, "ui.port" 8080, "nimbus.childopts" "-Xmx1024m", "storm.cluster.mode" "local", "topology.max.task.parallelism" nil, "storm.messaging.netty.transfer.batch.size" 262144}

  40. 3455 [main] INFO  org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting

  41. 3455 [main-EventThread] INFO  org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED

  42. 3455 [ConnectionStateManager-0] WARN  org.apache.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered.

  43. 3455 [main-EventThread] INFO  backtype.storm.zookeeper - Zookeeper state update: :connected:none

  44. 3455 [main] INFO  org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting

  45. 3455 [main-EventThread] INFO  org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED

  46. 3455 [ConnectionStateManager-0] WARN  org.apache.curator.framework.state.ConnectionStateManager - There are no ConnectionStateListeners registered.

  47. 3471 [main] INFO  backtype.storm.daemon.supervisor - Starting supervisor with id e97cff9d-df03-450c-90af-41ea36c6ceff at host Joker

  48. 3518 [main] INFO  backtype.storm.daemon.nimbus - Received topology submission for Topologie with conf {"topology.max.task.parallelism" nil, "topology.acker.executors" nil, "topology.kryo.register" nil, "topology.kryo.decorators" (), "topology.name" "Topologie", "storm.id" "Topologie-1-1416898017", "topology.debug" true, "words" "G:\\webspace\\stormDemo\\src\\words.txt", "topology.max.spout.pending" 1}

  49. 3549 [main] INFO  backtype.storm.daemon.nimbus - Activating Topologie: Topologie-1-1416898017

  50. 3658 [main] INFO  backtype.storm.scheduler.EvenScheduler - Available slots: (["8b5183d5-b921-43d0-b136-50ca470dc15f" 1024] ["8b5183d5-b921-43d0-b136-50ca470dc15f" 1025] ["8b5183d5-b921-43d0-b136-50ca470dc15f" 1026] ["e97cff9d-df03-450c-90af-41ea36c6ceff" 1027] ["e97cff9d-df03-450c-90af-41ea36c6ceff" 1028] ["e97cff9d-df03-450c-90af-41ea36c6ceff" 1029])

  51. 3674 [main] INFO  backtype.storm.daemon.nimbus - Setting new assignment for topology id Topologie-1-1416898017: #backtype.storm.daemon.common.Assignment{:master-code-dir "C:\\Users\\base\\AppData\\Local\\Temp\\7684ea21-4d8d-4923-9f88-dd64b24186e1\\nimbus\\stormdist\\Topologie-1-1416898017", :node->host {"8b5183d5-b921-43d0-b136-50ca470dc15f" "Joker"}, :executor->node+port {[4 4] ["8b5183d5-b921-43d0-b136-50ca470dc15f" 1024], [3 3] ["8b5183d5-b921-43d0-b136-50ca470dc15f" 1024], [2 2] ["8b5183d5-b921-43d0-b136-50ca470dc15f" 1024], [1 1] ["8b5183d5-b921-43d0-b136-50ca470dc15f" 1024], [5 5] ["8b5183d5-b921-43d0-b136-50ca470dc15f" 1024]}, :executor->start-time-secs {[5 5] 1416898017, [1 1] 1416898017, [2 2] 1416898017, [3 3] 1416898017, [4 4] 1416898017}}

  52. 3705 [main] INFO  backtype.storm.daemon.nimbus - Shutting down master

  53. 3721 [main] INFO  backtype.storm.daemon.nimbus - Shut down master

  54. 3721 [main] INFO  backtype.storm.daemon.supervisor - Shutting down supervisor 8b5183d5-b921-43d0-b136-50ca470dc15f

  55. 3721 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN  org.apache.zookeeper.server.NIOServerCnxn - caught end of stream exception

  56. org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x149e5b3f1490005, likely client has closed socket

  57.         at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:220) ~[zookeeper-3.4.5.jar:3.4.5-1392090]

  58.         at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [zookeeper-3.4.5.jar:3.4.5-1392090]

  59.         at java.lang.Thread.run(Unknown Source) [na:1.8.0_05]

  60. 3721 [Thread-3] INFO  backtype.storm.event - Event manager interrupted

  61. 3736 [Thread-4] INFO  backtype.storm.event - Event manager interrupted

  62. 3736 [main] INFO  backtype.storm.daemon.supervisor - Shutting down supervisor e97cff9d-df03-450c-90af-41ea36c6ceff

  63. 3736 [Thread-5] INFO  backtype.storm.event - Event manager interrupted

  64. 3736 [Thread-6] INFO  backtype.storm.event - Event manager interrupted

  65. 3736 [main] INFO  backtype.storm.testing - Shutting down in process zookeeper

  66. 3736 [main] INFO  backtype.storm.testing - Done shutting down in process zookeeper

  67. 3736 [main] INFO  backtype.storm.testing - Deleting temporary path C:\Users\base\AppData\Local\Temp\7684ea21-4d8d-4923-9f88-dd64b24186e1

  68. 3752 [main] INFO  backtype.storm.testing - Deleting temporary path C:\Users\base\AppData\Local\Temp\f63a50c6-fd7d-4cc5-8563-256cbe967dac

  69. 3752 [main] INFO  backtype.storm.testing - Unable to delete file: C:\Users\base\AppData\Local\Temp\f63a50c6-fd7d-4cc5-8563-256cbe967dac\version-2\log.1

  70. 3752 [main] INFO  backtype.storm.testing - Deleting temporary path C:\Users\base\AppData\Local\Temp\d96f0d72-7f06-4f41-9856-befc12c55ce2

  71. 3752 [main] INFO  backtype.storm.testing - Deleting temporary path C:\Users\base\AppData\Local\Temp\5cd74d33-4602-4360-bfe7-ec7dc4e3423b

复制代码

报了错误，
回复

使用道具 举报

自定义广告语

已有(5)人评论

跳转到指定楼层
正序浏览
nettman 发表于 2014-11-25 15:17:27
提示: 作者被禁止或删除 内容自动屏蔽
回复

使用道具 举报

Joker 发表于 2014-11-25 15:45:44
nettman 发表于 2014-11-25 15:17
storm一旦运行，就不会停止下来。
所以如果运行第二个程序的话，需要确保第一个程序已经被kill掉，否 ...

版主你好，我是在Windows上运行的，我在程序最后写了shutdown，而不是在集群上提交的？重启系统可以吗？
但是我从新放入虚拟机的Eclipse也是不行

一直提示

5344 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN  org.apache.zookeeper.server.NIOServerCnxn - caught end of stream exception
org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x149e5e520010002, likely client has closed socket
        at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:220) ~[zookeeper-3.4.5.jar:3.4.5-1392090]
        at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [zookeeper-3.4.5.jar:3.4.5-1392090]
        at java.lang.Thread.run(Thread.java:745) [na:1.7.0_67]


zookeeper连不上，我都是不是集群怎么连接
回复

使用道具 举报

desehawk 发表于 2014-11-25 17:27:46
本帖最后由 desehawk 于 2014-11-25 17:32 编辑
Joker 发表于 2014-11-25 15:45
版主你好，我是在Windows上运行的，我在程序最后写了shutdown，而不是在集群上提交的？重启系统可以吗？
...



虽然出现这个错误，但是结果应该是正常的吧

看下面diamante，应该是曾是一次没有读进来，然后报异常，但是程序应该继续往下执行了，不影响结果

/** Read the request payload (everything following the length prefix) */
    private void readPayload() throws IOException, InterruptedException {
        if (incomingBuffer.remaining() != 0) { // have we read length bytes?
                //尝试一次读进来
            int rc = sock.read(incomingBuffer); // sock is non-blocking, so ok
            if (rc < 0) {
                throw new EndOfStreamException(
                        "Unable to read additional data from client sessionid 0x"
                        + Long.toHexString(sessionId)
                        + ", likely client has closed socket");
            }
        }
     //一次读完
        if (incomingBuffer.remaining() == 0) { // have we read length bytes?
                //server的packet统计
            packetReceived();
                //准备使用这个buffer了
            incomingBuffer.flip();
                //如果CoonectRequst还没来，那第一个packet肯定是他了
            if (!initialized) {
                readConnectRequest();
            }
                //处理请他请求
            else {
                readRequest();
            }
                //清理现场，为下一个packet读做准备
            lenBuffer.clear();
            incomingBuffer = lenBuffer;
        }
    }


回复

使用道具 举报

Joker 发表于 2014-11-25 19:47:57
desehawk 发表于 2014-11-25 17:27
本帖最后由 desehawk 于 2014-11-25 17:32 编辑

但是没有把最终结果输出来，第一次能输出来！
回复

使用道具 举报

desehawk 发表于 2014-11-25 22:14:21
Joker 发表于 2014-11-25 15:45
版主你好，我是在Windows上运行的，我在程序最后写了shutdown，而不是在集群上提交的？重启系统可以吗？
...


Zookeeper建立session这里出现问题，看看是不是第一次影响了第二次

详细参考这个
Zookeeper源码分析之二Session建立

回复

使用道具 举报

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

发表新帖
Joker

高级会员

关注

  • 44

    主题

  • 271

    帖子

  • 3

    粉丝

TA的主题
关闭

推荐上一条 /2 下一条

关于我们· 联系我们· 加入我们· 小黑屋· 合作伙伴   

Copyright © 2001-2025 About云 Powered by Discuz! X3.4 Licensed Discuz Team.

简书 / Smrz 京ICP备2020039040号 Wxb 简书网举报电话：021-34700000