[ 
https://issues.apache.org/jira/browse/CASSANDRA-12926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Brandon Williams updated CASSANDRA-12926:
-----------------------------------------
    Resolution: Not A Problem
        Status: Resolved  (was: Open)

> RejectedExecutionException logged as SEVERE when task already completed
> -----------------------------------------------------------------------
>
>                 Key: CASSANDRA-12926
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-12926
>             Project: Cassandra
>          Issue Type: Improvement
>          Components: Legacy/Streaming and Messaging
>         Environment: 2.1.16
>            Reporter: Sebastien Bonnet
>            Priority: Low
>              Labels: pull-request-available
>          Time Spent: 0.5h
>  Remaining Estimate: 0h
>
> The issue is triggered by the MessagingService expiring a repair Snapshot 
> which Executor has already been shutdown and is an a TERMINATED state. 
> In this case trying to complete the SnapshotTask has little value, since the 
> Task is already completed. Yet the error is reported as SEVERE by the guava 
> library and shows in the journal logs. 
> Perhaps the Callback could check if the task is already complete before 
> setting the exception?
> https://github.com/apache/cassandra/blob/cassandra-2.1.16/src/java/org/apache/cassandra/repair/SnapshotTask.java#L78
>  
> {noformat}
> Nov 15, 2016 8:49:31 PM com.google.common.util.concurrent.ExecutionList 
> executeListener
> SEVERE: RuntimeException while executing runnable 
> com.google.common.util.concurrent.Futures$4@3df75dd9 with executor 
> com.google.common.util.concurrent.MoreExecutors$ListeningDecorator@370f36a9
> java.util.concurrent.RejectedExecutionException: Task 
> com.google.common.util.concurrent.Futures$4@3df75dd9 rejected from 
> java.util.concurrent.ThreadPoolExecutor@3330a417[Terminated, pool size = 0, 
> active threads = 0, queued tasks = 0, completed tasks = 17]
>         at 
> java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2047)
>         at 
> java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823)
>         at 
> java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369)
>         at 
> com.google.common.util.concurrent.MoreExecutors$ListeningDecorator.execute(MoreExecutors.java:484)
>         at 
> com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:156)
>         at 
> com.google.common.util.concurrent.ExecutionList.execute(ExecutionList.java:145)
>         at 
> com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:202)
>         at 
> com.google.common.util.concurrent.Futures$CombinedFuture.setExceptionAndMaybeLog(Futures.java:1566)
>         at 
> com.google.common.util.concurrent.Futures$CombinedFuture.setOneValue(Futures.java:1617)
>         at 
> com.google.common.util.concurrent.Futures$CombinedFuture.access$400(Futures.java:1470)
>         at 
> com.google.common.util.concurrent.Futures$CombinedFuture$2.run(Futures.java:1548)
>         at 
> com.google.common.util.concurrent.MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:297)
>         at 
> com.google.common.util.concurrent.ExecutionList.executeListener(ExecutionList.java:156)
>         at 
> com.google.common.util.concurrent.ExecutionList.execute(ExecutionList.java:145)
>         at 
> com.google.common.util.concurrent.AbstractFuture.setException(AbstractFuture.java:202)
>         at 
> org.apache.cassandra.repair.SnapshotTask.access$200(SnapshotTask.java:34)
>         at 
> org.apache.cassandra.repair.SnapshotTask$SnapshotCallback.onFailure(SnapshotTask.java:78)
>         at 
> org.apache.cassandra.net.MessagingService$5$1.run(MessagingService.java:374)
>         at 
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:266)
>         at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
>         at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
>         at java.lang.Thread.run(Thread.java:745)
> {noformat}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to