下面是我成功运行两三天后持续获得的异常的详细信息。有人能指导我吗?
2016-06-30 21:01:38.184 ERROR 6124 --- [ SyncThread:0] o.a.s.s.o.a.z.server.NIOServerCnxn : Unexpected Exception:
java.nio.channels.CancelledKeyException: null
at sun.nio.ch.SelectionKeyImpl.ensureValid(SelectionKeyImpl.java:73) ~[na:1.8.0_31]
at sun.nio.ch.SelectionKeyImpl.interestOps(SelectionKeyImpl.java:77) ~[na:1.8.0_31]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.sendBuffer(NIOServerCnxn.java:151) [storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.sendResponse(NIOServerCnxn.java:1081) [storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.FinalRequestProcessor.processRequest(FinalRequestProcessor.java:170) [storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.SyncRequestProcessor.flush(SyncRequestProcessor.java:200) [storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.SyncRequestProcessor.run(SyncRequestProcessor.java:131) [storm-core-1.0.1.jar:1.0.1]
2016-06-30 21:01:42.792 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Client session timed out, have not heard from server in 13334ms for sessionid 0x15595e58eec0008, closing socket connection and attempting reconnect
2016-06-30 21:01:42.792 WARN 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : caught end of stream exception
org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x15595e58eec0008, likely client has closed socket
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.0.1.jar:1.0.1]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_31]
2016-06-30 21:01:42.792 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : Closed socket connection for client /0:0:0:0:0:0:0:1:51483 which had sessionid 0x15595e58eec0008
2016-06-30 21:01:42.892 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: SUSPENDED
2016-06-30 21:01:42.892 WARN 6124 --- [ain-EventThread] o.a.s.c.zookeeper-state-factory : Received event :disconnected::none: with disconnected Writer Zookeeper.
2016-06-30 21:01:43.188 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Client session timed out, have not heard from server in 13334ms for sessionid 0x15595e58eec0000, closing socket connection and attempting reconnect
2016-06-30 21:01:43.188 WARN 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : caught end of stream exception
org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x15595e58eec0000, likely client has closed socket
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.0.1.jar:1.0.1]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_31]
2016-06-30 21:01:43.188 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : Closed socket connection for client /127.0.0.1:51487 which had sessionid 0x15595e58eec0000
2016-06-30 21:01:43.289 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: SUSPENDED
2016-06-30 21:01:43.289 INFO 6124 --- [ain-EventThread] org.apache.storm.zookeeper : Zookeeper state update: :disconnected:none
2016-06-30 21:01:43.350 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Client session timed out, have not heard from server in 13333ms for sessionid 0x15595e58eec0006, closing socket connection and attempting reconnect
2016-06-30 21:01:43.350 WARN 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : caught end of stream exception
org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x15595e58eec0006, likely client has closed socket
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.0.1.jar:1.0.1]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_31]
2016-06-30 21:01:43.350 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : Closed socket connection for client /0:0:0:0:0:0:0:1:51488 which had sessionid 0x15595e58eec0006
2016-06-30 21:01:43.380 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Opening socket connection to server 0:0:0:0:0:0:0:1/0:0:0:0:0:0:0:1:2000. Will not attempt to authenticate using SASL (unknown error)
2016-06-30 21:01:43.380 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Socket connection established to 0:0:0:0:0:0:0:1/0:0:0:0:0:0:0:1:2000, initiating session
2016-06-30 21:01:43.380 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.s.NIOServerCnxnFactory : Accepted socket connection from /0:0:0:0:0:0:0:1:51494
2016-06-30 21:01:43.380 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Client attempting to renew session 0x15595e58eec0000 at /0:0:0:0:0:0:0:1:51494
2016-06-30 21:01:43.380 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Established session 0x15595e58eec0000 with negotiated timeout 20000 for client /0:0:0:0:0:0:0:1:51494
2016-06-30 21:01:43.380 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Session establishment complete on server 0:0:0:0:0:0:0:1/0:0:0:0:0:0:0:1:2000, sessionid = 0x15595e58eec0000, negotiated timeout = 20000
2016-06-30 21:01:43.380 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: RECONNECTED
2016-06-30 21:01:43.381 INFO 6124 --- [ain-EventThread] org.apache.storm.zookeeper : Zookeeper state update: :connected:none
2016-06-30 21:01:43.451 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: SUSPENDED
2016-06-30 21:01:43.451 WARN 6124 --- [ain-EventThread] o.a.s.c.zookeeper-state-factory : Received event :disconnected::none: with disconnected Writer Zookeeper.
2016-06-30 21:01:43.462 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Client session timed out, have not heard from server in 13333ms for sessionid 0x15595e58eec0017, closing socket connection and attempting reconnect
2016-06-30 21:01:43.462 WARN 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : caught end of stream exception
org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x15595e58eec0017, likely client has closed socket
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.0.1.jar:1.0.1]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_31]
2016-06-30 21:01:43.462 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : Closed socket connection for client /0:0:0:0:0:0:0:1:51489 which had sessionid 0x15595e58eec0017
2016-06-30 21:01:43.563 INFO 6124 --- [-14-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: SUSPENDED
2016-06-30 21:01:43.563 WARN 6124 --- [-14-EventThread] o.a.s.c.zookeeper-state-factory : Received event :disconnected::none: with disconnected Writer Zookeeper.
2016-06-30 21:01:43.711 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Opening socket connection to server 127.0.0.1/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error)
2016-06-30 21:01:43.711 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Socket connection established to 127.0.0.1/127.0.0.1:2000, initiating session
2016-06-30 21:01:43.711 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.s.NIOServerCnxnFactory : Accepted socket connection from /127.0.0.1:51495
2016-06-30 21:01:43.711 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Client attempting to renew session 0x15595e58eec0008 at /127.0.0.1:51495
2016-06-30 21:01:43.711 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Established session 0x15595e58eec0008 with negotiated timeout 20000 for client /127.0.0.1:51495
2016-06-30 21:01:43.711 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Session establishment complete on server 127.0.0.1/127.0.0.1:2000, sessionid = 0x15595e58eec0008, negotiated timeout = 20000
2016-06-30 21:01:43.711 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: RECONNECTED
2016-06-30 21:01:43.727 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Client session timed out, have not heard from server in 13333ms for sessionid 0x15595e58eec0003, closing socket connection and attempting reconnect
2016-06-30 21:01:43.727 WARN 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : caught end of stream exception
org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x15595e58eec0003, likely client has closed socket
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.0.1.jar:1.0.1]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_31]
2016-06-30 21:01:43.727 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : Closed socket connection for client /127.0.0.1:51490 which had sessionid 0x15595e58eec0003
2016-06-30 21:01:43.797 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Client session timed out, have not heard from server in 13333ms for sessionid 0x15595e58eec0004, closing socket connection and attempting reconnect
2016-06-30 21:01:43.797 WARN 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : caught end of stream exception
org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x15595e58eec0004, likely client has closed socket
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.0.1.jar:1.0.1]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_31]
2016-06-30 21:01:43.797 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : Closed socket connection for client /0:0:0:0:0:0:0:1:51491 which had sessionid 0x15595e58eec0004
2016-06-30 21:01:43.827 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: SUSPENDED
2016-06-30 21:01:43.827 WARN 6124 --- [ain-EventThread] o.a.s.c.zookeeper-state-factory : Received event :disconnected::none: with disconnected Writer Zookeeper.
2016-06-30 21:01:43.898 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: SUSPENDED
2016-06-30 21:01:43.898 WARN 6124 --- [ain-EventThread] o.a.s.c.zookeeper-state-factory : Received event :disconnected::none: with disconnected Reader Zookeeper.
2016-06-30 21:01:43.902 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Opening socket connection to server 127.0.0.1/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error)
2016-06-30 21:01:43.902 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Socket connection established to 127.0.0.1/127.0.0.1:2000, initiating session
2016-06-30 21:01:43.902 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.s.NIOServerCnxnFactory : Accepted socket connection from /127.0.0.1:51496
2016-06-30 21:01:43.902 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Client attempting to renew session 0x15595e58eec0004 at /127.0.0.1:51496
2016-06-30 21:01:43.902 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Established session 0x15595e58eec0004 with negotiated timeout 20000 for client /127.0.0.1:51496
2016-06-30 21:01:43.902 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Session establishment complete on server 127.0.0.1/127.0.0.1:2000, sessionid = 0x15595e58eec0004, negotiated timeout = 20000
2016-06-30 21:01:43.902 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: RECONNECTED
2016-06-30 21:01:43.960 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Client session timed out, have not heard from server in 13334ms for sessionid 0x15595e58eec0001, closing socket connection and attempting reconnect
2016-06-30 21:01:43.960 WARN 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : caught end of stream exception
org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x15595e58eec0001, likely client has closed socket
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.0.1.jar:1.0.1]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_31]
2016-06-30 21:01:43.960 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : Closed socket connection for client /127.0.0.1:51492 which had sessionid 0x15595e58eec0001
2016-06-30 21:01:44.061 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: SUSPENDED
2016-06-30 21:01:44.103 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Opening socket connection to server 127.0.0.1/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error)
2016-06-30 21:01:44.103 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Socket connection established to 127.0.0.1/127.0.0.1:2000, initiating session
2016-06-30 21:01:44.103 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.s.NIOServerCnxnFactory : Accepted socket connection from /127.0.0.1:51497
2016-06-30 21:01:44.103 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Client attempting to renew session 0x15595e58eec0006 at /127.0.0.1:51497
2016-06-30 21:01:44.103 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Established session 0x15595e58eec0006 with negotiated timeout 20000 for client /127.0.0.1:51497
2016-06-30 21:01:44.103 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Session establishment complete on server 127.0.0.1/127.0.0.1:2000, sessionid = 0x15595e58eec0006, negotiated timeout = 20000
2016-06-30 21:01:44.103 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: RECONNECTED
2016-06-30 21:01:44.161 INFO 6124 --- [127.0.0.1:2000)]
[ . . . ]
o.a.s.s.org.apache.zookeeper.ClientCnxn : Opening socket connection to server 0:0:0:0:0:0:0:1/0:0:0:0:0:0:0:1:2000. Will not attempt to authenticate using SASL (unknown error)
2016-06-30 21:01:44.222 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.s.NIOServerCnxnFactory : Accepted socket connection from /0:0:0:0:0:0:0:1:51499
2016-06-30 21:01:44.222 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Socket connection established to 0:0:0:0:0:0:0:1/0:0:0:0:0:0:0:1:2000, initiating session
2016-06-30 21:01:44.222 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Client attempting to renew session 0x15595e58eec0003 at /0:0:0:0:0:0:0:1:51499
2016-06-30 21:01:44.222 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Established session 0x15595e58eec0003 with negotiated timeout 20000 for client /0:0:0:0:0:0:0:1:51499
2016-06-30 21:01:44.222 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Session establishment complete on server 0:0:0:0:0:0:0:1/0:0:0:0:0:0:0:1:2000, sessionid = 0x15595e58eec0003, negotiated timeout = 20000
2016-06-30 21:01:44.222 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: RECONNECTED
2016-06-30 21:01:44.916 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Opening socket connection to server 0:0:0:0:0:0:0:1/0:0:0:0:0:0:0:1:2000. Will not attempt to authenticate using SASL (unknown error)
2016-06-30 21:01:44.916 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Socket connection established to 0:0:0:0:0:0:0:1/0:0:0:0:0:0:0:1:2000, initiating session
2016-06-30 21:01:44.916 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.s.NIOServerCnxnFactory : Accepted socket connection from /0:0:0:0:0:0:0:1:51500
2016-06-30 21:01:44.916 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Client attempting to renew session 0x15595e58eec0001 at /0:0:0:0:0:0:0:1:51500
2016-06-30 21:01:44.916 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.ZooKeeperServer : Established session 0x15595e58eec0001 with negotiated timeout 20000 for client /0:0:0:0:0:0:0:1:51500
2016-06-30 21:01:44.917 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Session establishment complete on server 0:0:0:0:0:0:0:1/0:0:0:0:0:0:0:1:2000, sessionid = 0x15595e58eec0001, negotiated timeout = 20000
2016-06-30 21:01:44.917 INFO 6124 --- [ain-EventThread] o.a.s.s.o.a.c.f.s.ConnectionStateManager : State change: RECONNECTED
2016-06-30 21:01:51.465 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.supervisor : Shutting down and clearing state for id ed72f1e3-177c-43c9-8456-85b2110e5474. Current supervisor time: 1467320495. State: :timed-out, Heartbeat: {:time-secs 1467320448, :storm-id "kafka-1-1467098698", :executors [[8 8] [2 2] [7 7] [3 3] [1 1] [6 6] [9 9] [11 11] [-1 -1] [5 5] [10 10] [4 4]], :port 1027}
2016-06-30 21:01:51.465 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.supervisor : Shutting down 822c206b-1c84-4c00-bbec-d735a4a1bbae:ed72f1e3-177c-43c9-8456-85b2110e5474
2016-06-30 21:01:51.465 INFO 6124 --- [ Thread-14] org.apache.storm.config : GET worker-user ed72f1e3-177c-43c9-8456-85b2110e5474
2016-06-30 21:01:51.467 INFO 6124 --- [ Thread-14] org.apache.storm.process-simulator : Killing process bd3f029a-4da8-4390-9a4f-8b2e25a26b52
2016-06-30 21:01:51.467 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.worker : Shutting down worker kafka-1-1467098698 822c206b-1c84-4c00-bbec-d735a4a1bbae 1027
2016-06-30 21:01:51.467 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.worker : Terminating messaging context
2016-06-30 21:01:51.467 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.worker : Shutting down executors
2016-06-30 21:01:51.467 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shutting down executor NotificationProcessorBolt:[8 8]
2016-06-30 21:01:51.467 INFO 6124 --- [t-executor[8 8]] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.467 INFO 6124 --- [8 8]-send-queue] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.468 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shut down executor NotificationProcessorBolt:[8 8]
2016-06-30 21:01:51.468 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shutting down executor NotificationProcessorBolt:[2 2]
2016-06-30 21:01:51.468 INFO 6124 --- [2 2]-send-queue] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.468 INFO 6124 --- [t-executor[2 2]] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.468 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shut down executor NotificationProcessorBolt:[2 2]
2016-06-30 21:01:51.468 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shutting down executor NotificationProcessorBolt:[7 7]
2016-06-30 21:01:51.468 INFO 6124 --- [t-executor[7 7]] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.468 INFO 6124 --- [7 7]-send-queue] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.469 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shut down executor NotificationProcessorBolt:[7 7]
2016-06-30 21:01:51.469 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shutting down executor NotificationProcessorBolt:[3 3]
2016-06-30 21:01:51.469 INFO 6124 --- [3 3]-send-queue] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.469 INFO 6124 --- [t-executor[3 3]] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.469 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shut down executor NotificationProcessorBolt:[3 3]
2016-06-30 21:01:51.469 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shutting down executor NotificationProcessorBolt:[1 1]
2016-06-30 21:01:51.469 INFO 6124 --- [t-executor[1 1]] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.470 INFO 6124 --- [1 1]-send-queue] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.470 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shut down executor NotificationProcessorBolt:[1 1]
2016-06-30 21:01:51.470 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shutting down executor NotificationProcessorBolt:[6 6]
2016-06-30 21:01:51.470 INFO 6124 --- [t-executor[6 6]] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.470 INFO 6124 --- [6 6]-send-queue] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.470 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shut down executor NotificationProcessorBolt:[6 6]
2016-06-30 21:01:51.470 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shutting down executor __acker:[9 9]
2016-06-30 21:01:51.470 INFO 6124 --- [r-executor[9 9]] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.470 INFO 6124 --- [9 9]-send-queue] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.470 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shut down executor __acker:[9 9]
2016-06-30 21:01:51.470 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shutting down executor streamProcessorBolt:[11 11]
2016-06-30 21:01:51.471 INFO 6124 --- [executor[11 11]] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.471 INFO 6124 --- [ 11]-send-queue] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.471 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shut down executor streamProcessorBolt:[11 11]
2016-06-30 21:01:51.471 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shutting down executor __system:[-1 -1]
2016-06-30 21:01:51.471 INFO 6124 --- [ -1]-send-queue] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.471 INFO 6124 --- [executor[-1 -1]] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.472 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shut down executor __system:[-1 -1]
2016-06-30 21:01:51.472 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shutting down executor NotificationProcessorBolt:[5 5]
2016-06-30 21:01:51.472 INFO 6124 --- [t-executor[5 5]] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.472 INFO 6124 --- [5 5]-send-queue] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.473 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shut down executor NotificationProcessorBolt:[5 5]
2016-06-30 21:01:51.473 INFO 6124 --- [ Thread-14] org.apache.storm.daemon.executor : Shutting down executor spout:[10 10]
2016-06-30 21:01:51.473 INFO 6124 --- [ 10]-send-queue] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.473 INFO 6124 --- [executor[10 10]] org.apache.storm.util : Async loop interrupted!
2016-06-30 21:01:51.473 INFO 6124 --- [tor-Framework-0] o.a.c.f.imps.CuratorFrameworkImpl : backgroundOperationsLoop exiting
2016-06-30 21:01:51.474 INFO 6124 --- [id:0 cport:-1):] o.a.s.s.o.a.z.s.PrepRequestProcessor : Processed session termination for sessionid: 0x15595e58eec0018
2016-06-30 21:01:51.517 INFO 6124 --- [0:0:0:0:1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Client session timed out, have not heard from server in 13333ms for sessionid 0x15595e58eec000c, closing socket connection and attempting reconnect
2016-06-30 21:01:51.517 WARN 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : caught end of stream exception
org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x15595e58eec000c, likely client has closed socket
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.0.1.jar:1.0.1]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_31]
2016-06-30 21:01:51.517 INFO 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : Closed socket connection for client /0:0:0:0:0:0:0:1:51484 which had sessionid 0x15595e58eec000c
2016-06-30 21:01:51.518 INFO 6124 --- [127.0.0.1:2000)] o.a.s.s.org.apache.zookeeper.ClientCnxn : Client session timed out, have not heard from server in 13333ms for sessionid 0x15595e58eec000a, closing socket connection and attempting reconnect
2016-06-30 21:01:51.518 WARN 6124 --- [.0/0.0.0.0:2000] o.a.s.s.o.a.z.server.NIOServerCnxn : caught end of stream exception
org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x15595e58eec000a, likely client has closed socket
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.0.1.jar:1.0.1]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_31]
看起来本地storm实例无法连接到嵌入的Zookeeper实例。
这可能会帮助您:
动物园管理员出错
Storm创建拓扑
Apache Kafka:分布式消息传递系统 Apache Storm:实时消息处理 我们如何在实时数据管道中使用这两种技术来处理事件数据? 在实时数据管道方面,我觉得两者做的工作是一样的。如何在数据管道上同时使用这两种技术?
我正试图找出这两种设置之间的区别。大小和缓冲区。Kafka制作人的记忆。 据我所知。大小:这是可以发送的批次的最大大小。 文档描述了缓冲区。memory as:生产者可以用来缓冲等待发送的记录的内存字节。 我不明白这两者之间的区别。有人能解释一下吗? 谢啦
我们需要的是直接的API来设置和使用集群消息队列。我们最初的计划是使用Camel在集群JMS或ActiveMQ队列上进行消费/生产。Kafka如何使这项任务变得更容易?在任何一种情况下,应用程序本身都将在WebLogic服务器上运行。 消息传递将是点对点类型,其中有多个相同服务的实例在运行,但根据负载平衡策略,只有一个实例应该处理消息并发出结果。消息队列也是群集的,因此服务实例或队列实例的失败都不
我正在使用Flink从Apache Pulsar读取数据。我在pulsar中有一个分区主题,有8个分区。在本主题中,我生成了1000条消息,分布在8个分区中。我的笔记本电脑中有8个内核,因此我有8个子任务(默认情况下,并行度=#个内核)。在执行Eclipse中的代码后,我打开了Flink UI,发现一些子任务没有收到任何记录(空闲)。我希望所有8个子任务都能得到利用(我希望每个子任务都映射到我的主
目前我正在研究Apache spark和Apache ignite框架。 这篇文章介绍了它们之间的一些原则差异,但我意识到我仍然不理解它们的目的。 我的意思是,哪一个问题更容易产生火花而不是点燃,反之亦然?
我正在做一个学术项目,涉及传感器的流数据。我已经包围了苍鹭(Storm的接班人)和尼菲。两者都支持内置背压,这对我的项目至关重要。Apache Nifi和Heron之间的主要区别是什么? 哪款更适合物联网应用?