You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by "Jonathan Ellis (JIRA)" <ji...@apache.org> on 2009/05/12 21:20:45 UTC
[jira] Created: (CASSANDRA-165) RejectedExecutionException in
getKeyRange
RejectedExecutionException in getKeyRange
-----------------------------------------
Key: CASSANDRA-165
URL: https://issues.apache.org/jira/browse/CASSANDRA-165
Project: Cassandra
Issue Type: Bug
Reporter: Jonathan Ellis
Assignee: Jonathan Ellis
Haven't been able to repro in unit tests but fails in system tests about 50% of the time.
java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException
at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:27)
at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
Caused by: java.util.concurrent.RejectedExecutionException
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
at org.apache.cassandra.db.Memtable.sortedKeyIterator(Memtable.java:412)
at org.apache.cassandra.db.Table.getKeyRangeUnsafe(Table.java:912)
at org.apache.cassandra.db.Table.getKeyRange(Table.java:883)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Reopened: (CASSANDRA-165) RejectedExecutionException in
getKeyRange
Posted by "Jonathan Ellis (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/CASSANDRA-165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jonathan Ellis reopened CASSANDRA-165:
--------------------------------------
[commented on 163 initially by mistake]
here is the problem
void put(String key, ColumnFamily columnFamily, CommitLog.CommitLogContext cLogCtx) throws IOException
{
isDirty_ = true;
executor_.submit(new Putter(key, columnFamily));
if (isThresholdViolated())
{
enqueueFlush(cLogCtx);
}
}
(enqueueFlush is the one that swaps out this memtable for a new one in CFS and calls shutdown)
the problem is that we submit first and ask questions later, so we can clearly submit to this [old] memtable on one thread after another thread starts the shutdown.
the only option I see is going to back to the old double-checked-ish logic of checking threshold first, then recursing to resubmit if we switch memtables. (overriding TPE.execute/addIfUnderMaximumPoolSize is not an option since liberal use of private variables is made.)
> RejectedExecutionException in getKeyRange
> -----------------------------------------
>
> Key: CASSANDRA-165
> URL: https://issues.apache.org/jira/browse/CASSANDRA-165
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 0.3
> Reporter: Jonathan Ellis
> Assignee: Jonathan Ellis
> Fix For: 0.3
>
> Attachments: CASSANDRA-165.patch
>
>
> Haven't been able to repro in unit tests but fails in system tests about 50% of the time.
> java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException
> at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:27)
> at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: java.util.concurrent.RejectedExecutionException
> at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
> at org.apache.cassandra.db.Memtable.sortedKeyIterator(Memtable.java:412)
> at org.apache.cassandra.db.Table.getKeyRangeUnsafe(Table.java:912)
> at org.apache.cassandra.db.Table.getKeyRange(Table.java:883)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Commented: (CASSANDRA-165) RejectedExecutionException in
getKeyRange
Posted by "Eric Evans (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/CASSANDRA-165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12708667#action_12708667 ]
Eric Evans commented on CASSANDRA-165:
--------------------------------------
Spoke too soon. After more local test runs, I got a RejectedExecutionException in the same place.
> RejectedExecutionException in getKeyRange
> -----------------------------------------
>
> Key: CASSANDRA-165
> URL: https://issues.apache.org/jira/browse/CASSANDRA-165
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 0.3
> Reporter: Jonathan Ellis
> Assignee: Jonathan Ellis
> Fix For: 0.3
>
> Attachments: CASSANDRA-165.patch
>
>
> Haven't been able to repro in unit tests but fails in system tests about 50% of the time.
> java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException
> at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:27)
> at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: java.util.concurrent.RejectedExecutionException
> at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
> at org.apache.cassandra.db.Memtable.sortedKeyIterator(Memtable.java:412)
> at org.apache.cassandra.db.Table.getKeyRangeUnsafe(Table.java:912)
> at org.apache.cassandra.db.Table.getKeyRange(Table.java:883)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Updated: (CASSANDRA-165) RejectedExecutionException in
getKeyRange
Posted by "Jonathan Ellis (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/CASSANDRA-165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jonathan Ellis updated CASSANDRA-165:
-------------------------------------
Attachment: CASSANDRA-165.patch
> RejectedExecutionException in getKeyRange
> -----------------------------------------
>
> Key: CASSANDRA-165
> URL: https://issues.apache.org/jira/browse/CASSANDRA-165
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 0.3
> Reporter: Jonathan Ellis
> Assignee: Jonathan Ellis
> Fix For: 0.3
>
> Attachments: CASSANDRA-165.patch
>
>
> Haven't been able to repro in unit tests but fails in system tests about 50% of the time.
> java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException
> at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:27)
> at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: java.util.concurrent.RejectedExecutionException
> at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
> at org.apache.cassandra.db.Memtable.sortedKeyIterator(Memtable.java:412)
> at org.apache.cassandra.db.Table.getKeyRangeUnsafe(Table.java:912)
> at org.apache.cassandra.db.Table.getKeyRange(Table.java:883)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Commented: (CASSANDRA-165) RejectedExecutionException in
getKeyRange
Posted by "Hudson (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/CASSANDRA-165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12708850#action_12708850 ]
Hudson commented on CASSANDRA-165:
----------------------------------
Integrated in Cassandra #73 (See [http://hudson.zones.apache.org/hudson/job/Cassandra/73/])
to avoid adding work to terminating executor (which will raise an exception) we need to check for threshold violated _first_, and move puts to the new memtable once flush has started. patch by jbellis; reviewed by Eric Evans for
> RejectedExecutionException in getKeyRange
> -----------------------------------------
>
> Key: CASSANDRA-165
> URL: https://issues.apache.org/jira/browse/CASSANDRA-165
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 0.3
> Reporter: Jonathan Ellis
> Assignee: Jonathan Ellis
> Fix For: 0.3
>
> Attachments: CASSANDRA-165.patch
>
>
> Haven't been able to repro in unit tests but fails in system tests about 50% of the time.
> java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException
> at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:27)
> at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: java.util.concurrent.RejectedExecutionException
> at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
> at org.apache.cassandra.db.Memtable.sortedKeyIterator(Memtable.java:412)
> at org.apache.cassandra.db.Table.getKeyRangeUnsafe(Table.java:912)
> at org.apache.cassandra.db.Table.getKeyRange(Table.java:883)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Commented: (CASSANDRA-165) RejectedExecutionException in
getKeyRange
Posted by "Eric Evans (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/CASSANDRA-165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12708662#action_12708662 ]
Eric Evans commented on CASSANDRA-165:
--------------------------------------
+1
> RejectedExecutionException in getKeyRange
> -----------------------------------------
>
> Key: CASSANDRA-165
> URL: https://issues.apache.org/jira/browse/CASSANDRA-165
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 0.3
> Reporter: Jonathan Ellis
> Assignee: Jonathan Ellis
> Fix For: 0.3
>
> Attachments: CASSANDRA-165.patch
>
>
> Haven't been able to repro in unit tests but fails in system tests about 50% of the time.
> java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException
> at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:27)
> at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: java.util.concurrent.RejectedExecutionException
> at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
> at org.apache.cassandra.db.Memtable.sortedKeyIterator(Memtable.java:412)
> at org.apache.cassandra.db.Table.getKeyRangeUnsafe(Table.java:912)
> at org.apache.cassandra.db.Table.getKeyRange(Table.java:883)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Updated: (CASSANDRA-165) RejectedExecutionException in
getKeyRange
Posted by "Jonathan Ellis (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/CASSANDRA-165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jonathan Ellis updated CASSANDRA-165:
-------------------------------------
Attachment: 165-2-v2.patch
fixes regression mentioned in IRC. (need to use a writelock for the put call too, not just the memtable switch. duh.)
> RejectedExecutionException in getKeyRange
> -----------------------------------------
>
> Key: CASSANDRA-165
> URL: https://issues.apache.org/jira/browse/CASSANDRA-165
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 0.3
> Reporter: Jonathan Ellis
> Assignee: Jonathan Ellis
> Fix For: 0.3
>
> Attachments: 165-2-v2.patch, 165-2.patch, CASSANDRA-165.patch
>
>
> Haven't been able to repro in unit tests but fails in system tests about 50% of the time.
> java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException
> at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:27)
> at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: java.util.concurrent.RejectedExecutionException
> at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
> at org.apache.cassandra.db.Memtable.sortedKeyIterator(Memtable.java:412)
> at org.apache.cassandra.db.Table.getKeyRangeUnsafe(Table.java:912)
> at org.apache.cassandra.db.Table.getKeyRange(Table.java:883)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Updated: (CASSANDRA-165) RejectedExecutionException in
getKeyRange
Posted by "Jonathan Ellis (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/CASSANDRA-165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jonathan Ellis updated CASSANDRA-165:
-------------------------------------
Attachment: 165-2.patch
replace executor with locking. the interaction between the executor service terminating and the CFS
was inherently unsafe -- you would have to lock anyway to make it safe, the atomic reference wasn't
enough, so at that point you might as well get rid of the executor.
> RejectedExecutionException in getKeyRange
> -----------------------------------------
>
> Key: CASSANDRA-165
> URL: https://issues.apache.org/jira/browse/CASSANDRA-165
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 0.3
> Reporter: Jonathan Ellis
> Assignee: Jonathan Ellis
> Fix For: 0.3
>
> Attachments: 165-2.patch, CASSANDRA-165.patch
>
>
> Haven't been able to repro in unit tests but fails in system tests about 50% of the time.
> java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException
> at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:27)
> at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: java.util.concurrent.RejectedExecutionException
> at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
> at org.apache.cassandra.db.Memtable.sortedKeyIterator(Memtable.java:412)
> at org.apache.cassandra.db.Table.getKeyRangeUnsafe(Table.java:912)
> at org.apache.cassandra.db.Table.getKeyRange(Table.java:883)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Updated: (CASSANDRA-165) RejectedExecutionException in
getKeyRange
Posted by "Jonathan Ellis (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/CASSANDRA-165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jonathan Ellis updated CASSANDRA-165:
-------------------------------------
Fix Version/s: 0.3
Affects Version/s: 0.3
> RejectedExecutionException in getKeyRange
> -----------------------------------------
>
> Key: CASSANDRA-165
> URL: https://issues.apache.org/jira/browse/CASSANDRA-165
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 0.3
> Reporter: Jonathan Ellis
> Assignee: Jonathan Ellis
> Fix For: 0.3
>
>
> Haven't been able to repro in unit tests but fails in system tests about 50% of the time.
> java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException
> at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:27)
> at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: java.util.concurrent.RejectedExecutionException
> at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
> at org.apache.cassandra.db.Memtable.sortedKeyIterator(Memtable.java:412)
> at org.apache.cassandra.db.Table.getKeyRangeUnsafe(Table.java:912)
> at org.apache.cassandra.db.Table.getKeyRange(Table.java:883)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Commented: (CASSANDRA-165) RejectedExecutionException in
getKeyRange
Posted by "Eric Evans (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/CASSANDRA-165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12709154#action_12709154 ]
Eric Evans commented on CASSANDRA-165:
--------------------------------------
+1
> RejectedExecutionException in getKeyRange
> -----------------------------------------
>
> Key: CASSANDRA-165
> URL: https://issues.apache.org/jira/browse/CASSANDRA-165
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 0.3
> Reporter: Jonathan Ellis
> Assignee: Jonathan Ellis
> Fix For: 0.3
>
> Attachments: 165-2-v2.patch, 165-2.patch, CASSANDRA-165.patch
>
>
> Haven't been able to repro in unit tests but fails in system tests about 50% of the time.
> java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException
> at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:27)
> at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: java.util.concurrent.RejectedExecutionException
> at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
> at org.apache.cassandra.db.Memtable.sortedKeyIterator(Memtable.java:412)
> at org.apache.cassandra.db.Table.getKeyRangeUnsafe(Table.java:912)
> at org.apache.cassandra.db.Table.getKeyRange(Table.java:883)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Resolved: (CASSANDRA-165) RejectedExecutionException in
getKeyRange
Posted by "Jonathan Ellis (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/CASSANDRA-165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jonathan Ellis resolved CASSANDRA-165.
--------------------------------------
Resolution: Fixed
> RejectedExecutionException in getKeyRange
> -----------------------------------------
>
> Key: CASSANDRA-165
> URL: https://issues.apache.org/jira/browse/CASSANDRA-165
> Project: Cassandra
> Issue Type: Bug
> Affects Versions: 0.3
> Reporter: Jonathan Ellis
> Assignee: Jonathan Ellis
> Fix For: 0.3
>
> Attachments: CASSANDRA-165.patch
>
>
> Haven't been able to repro in unit tests but fails in system tests about 50% of the time.
> java.lang.RuntimeException: java.util.concurrent.RejectedExecutionException
> at org.apache.cassandra.service.RangeVerbHandler.doVerb(RangeVerbHandler.java:27)
> at org.apache.cassandra.net.MessageDeliveryTask.run(MessageDeliveryTask.java:46)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:619)
> Caused by: java.util.concurrent.RejectedExecutionException
> at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:1760)
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:767)
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:658)
> at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:92)
> at org.apache.cassandra.db.Memtable.sortedKeyIterator(Memtable.java:412)
> at org.apache.cassandra.db.Table.getKeyRangeUnsafe(Table.java:912)
> at org.apache.cassandra.db.Table.getKeyRange(Table.java:883)
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.