[ 
https://issues.apache.org/jira/browse/CASSANDRA-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12907399#action_12907399
 ] 

David King commented on CASSANDRA-1483:
---------------------------------------

For my particular use-case calling sys.exit is actually undesirable. But that 
aside, the log message could just be improved. Instead of looking like an 
exception, it could just say "Rejected connection from $x because I'm not 
really alive"

> RejectedExecutionException thrown on decommissioned node
> --------------------------------------------------------
>
>                 Key: CASSANDRA-1483
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-1483
>             Project: Cassandra
>          Issue Type: Improvement
>          Components: Core
>    Affects Versions: 0.6
>            Reporter: David King
>            Priority: Minor
>             Fix For: 0.6.6
>
>
> This probably has no effect, but after decommissioning a node, it continues 
> to throw java.util.concurrent.RejectedExecutionException:
> {quote}
>  INFO 11:36:19,436 Waiting for transfer to /10.251.115.127 to complete
>  INFO 11:36:45,638 Creating new commitlog segment 
> /cassandra/commitlog/CommitLog-1283971005638.log
>  INFO 11:38:09,608 Done with transfer to /10.251.115.127
>  INFO 11:38:11,615 Shutting down MessageService...
>  INFO 11:38:11,617 MessagingService shutting down server thread.
>  INFO 11:38:11,619 Shutdown complete (no further commands will be processed)
>  INFO 11:38:11,636 Decommissioned
> ERROR 11:38:13,196 Uncaught exception in thread Thread[Thread-53,5,main]
> java.util.concurrent.RejectedExecutionException: ThreadPoolExecutor has shut 
> down
>         at 
> org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor$1.rejectedExecution(DebuggableThreadPoolExecutor.java:61)
>         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:392)
>         at 
> org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:76)
> ERROR 11:38:13,612 Uncaught exception in thread Thread[Thread-1159,5,main]
> java.util.concurrent.RejectedExecutionException: ThreadPoolExecutor has shut 
> down
>         at 
> org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor$1.rejectedExecution(DebuggableThreadPoolExecutor.java:61)
>         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:392)
>         at 
> org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:76)
> ERROR 11:38:13,651 Uncaught exception in thread Thread[Thread-1157,5,main]
> java.util.concurrent.RejectedExecutionException: ThreadPoolExecutor has shut 
> down
>         at 
> org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor$1.rejectedExecution(DebuggableThreadPoolExecutor.java:61)
>         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:392)
>         at 
> org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:76)
> ERROR 11:38:13,904 Uncaught exception in thread Thread[Thread-61,5,main]
> java.util.concurrent.RejectedExecutionException: ThreadPoolExecutor has shut 
> down
>         at 
> org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor$1.rejectedExecution(DebuggableThreadPoolExecutor.java:61)
>         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:392)
>         at 
> org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:76)
> ERROR 11:38:16,520 Uncaught exception in thread Thread[Thread-133,5,main]
> java.util.concurrent.RejectedExecutionException: ThreadPoolExecutor has shut 
> down
>         at 
> org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor$1.rejectedExecution(DebuggableThreadPoolExecutor.java:61)
>         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:392)
>         at 
> org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:76)
> ERROR 11:38:18,480 Uncaught exception in thread Thread[Thread-51,5,main]
> java.util.concurrent.RejectedExecutionException: ThreadPoolExecutor has shut 
> down
>         at 
> org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor$1.rejectedExecution(DebuggableThreadPoolExecutor.java:61)
>         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:392)
>         at 
> org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:76)
> ERROR 11:38:19,052 Uncaught exception in thread Thread[Thread-60,5,main]
> java.util.concurrent.RejectedExecutionException: ThreadPoolExecutor has shut 
> down
>         at 
> org.apache.cassandra.concurrent.DebuggableThreadPoolExecutor$1.rejectedExecution(DebuggableThreadPoolExecutor.java:61)
>         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:392)
>         at 
> org.apache.cassandra.net.IncomingTcpConnection.run(IncomingTcpConnection.java:76)
> [...]
>  INFO 11:43:34,655 LocationInfo has reached its threshold; switching in a 
> fresh Memtable at 
> CommitLogContext(file='/cassandra/commitlog/CommitLog-1283971005638.log', 
> position=8400377)
>  INFO 11:43:34,656 Enqueuing flush of memtable-locationi...@471028214(17 
> bytes, 1 operations)
>  INFO 11:43:34,657 Writing memtable-locationi...@471028214(17 bytes, 1 
> operations)
>  INFO 11:43:34,721 Completed flushing 
> /cassandra/data/system/LocationInfo-59-Data.db
>  INFO 11:43:34,724 Discarding obsolete commit 
> log:CommitLogSegment(/cassandra/commitlog/CommitLog-1283926504227.log)
> {quote}

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.

Reply via email to