我的 cassandra 集群的环正在跟随。
Address DC Rack Status State Load Effective-Ownership Token
159798937583215624764598934804025953415
172.16.228.113 datacenter1 rack1 Up Normal 79.93 KB 37.41% 53308554391200048212055997923356692434
172.16.228.111 datacenter1 rack1 Up Normal 27.74 MB 7.20% 65566706948329075554413307447708030255
172.16.228.112 datacenter1 rack1 Up Normal 49.17 MB 55.38% 159798937583215624764598934804025953415
由于维护,我想重新启动一个节点。所以我尝试执行“./bin/nodetool -h localhost decommission”。
几分钟过去后,我在“system.log”上收到以下错误消息。我没有得到“decommission”命令的响应,所以我用“CTRL + C”完成了这个过程。
ERROR [Thread-18] 2012-11-23 11:23:29,249 AbstractCassandraDaemon.java (line 135) Exception in thread Thread[Thread-18,5,main]
java.util.concurrent.RejectedExecutionException: ThreadPoolExecutor has shut down
at org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor$1.rejectedExecution(DebuggableThreadPoolExecutor.java:60)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:816)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1337)
at org.apache.cassandra.net.MessagingService.receive(MessagingService.java:566)
at org.apache.cassandra.net.IncomingTcpConnection.receiveMessage(IncomingTcpConnection.java:155)
at org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:113)
ERROR [Thread-5] 2012-11-23 11:23:29,251 AbstractCassandraDaemon.java (line 135) Exception in thread Thread[Thread-5,5,main]
java.util.concurrent.RejectedExecutionException: ThreadPoolExecutor has shut down
at org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor$1.rejectedExecution(DebuggableThreadPoolExecutor.java:60)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:816)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1337)
at org.apache.cassandra.net.MessagingService.receive(MessagingService.java:566)
at org.apache.cassandra.net.IncomingTcpConnection.receiveMessage(IncomingTcpConnection.java:155)
at org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:113)
这个消息是什么意思,请给我解决方案。