You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@geode.apache.org by "Darrel Schneider (JIRA)" <ji...@apache.org> on 2016/05/25 17:09:12 UTC
[jira] [Resolved] (GEODE-1428) Cache close will log a warning and
not dispatch the cache close event if the sys prop
gemfire.Cache.ASYNC_EVENT_LISTENERS is set to true
[ https://issues.apache.org/jira/browse/GEODE-1428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Darrel Schneider resolved GEODE-1428.
-------------------------------------
Resolution: Fixed
Fix Version/s: 1.0.0-incubating.M3
> Cache close will log a warning and not dispatch the cache close event if the sys prop gemfire.Cache.ASYNC_EVENT_LISTENERS is set to true
> ----------------------------------------------------------------------------------------------------------------------------------------
>
> Key: GEODE-1428
> URL: https://issues.apache.org/jira/browse/GEODE-1428
> Project: Geode
> Issue Type: Bug
> Components: regions
> Reporter: Darrel Schneider
> Assignee: Darrel Schneider
> Fix For: 1.0.0-incubating.M3
>
>
> If you enable async cache listeners then during cache close the dispatch of the cache close event will be rejected because the pool has already shutdown. The code that uses the async pool currently catches RejectedExecutionException and logs it. It should instead just do a synchronous invocation of the listener.
> Here is the stack you will see:
> [warn 2016/05/20 17:16:07.107 PDT <main> tid=0x1] {0} Event not dispatched due to rejected execution
> java.util.concurrent.RejectedExecutionException: executor has been shutdown
> at com.gemstone.gemfire.distributed.internal.PooledExecutorWithDMStats$BufferHandler.rejectedExecution(PooledExecutorWithDMStats.java:220)
> at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823)
> at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369)
> at com.gemstone.gemfire.internal.cache.LocalRegion.dispatchListenerEvent(LocalRegion.java:7591)
> at com.gemstone.gemfire.internal.cache.LocalRegion.sendPendingRegionDestroyEvents(LocalRegion.java:7850)
> at com.gemstone.gemfire.internal.cache.LocalRegion.basicDestroyRegion(LocalRegion.java:6853)
> at com.gemstone.gemfire.internal.cache.DistributedRegion.basicDestroyRegion(DistributedRegion.java:1917)
> at com.gemstone.gemfire.internal.cache.LocalRegion.handleCacheClose(LocalRegion.java:7934)
> at com.gemstone.gemfire.internal.cache.DistributedRegion.handleCacheClose(DistributedRegion.java:2825)
> at com.gemstone.gemfire.internal.cache.GemFireCacheImpl.close(GemFireCacheImpl.java:2149)
> at com.gemstone.gemfire.internal.cache.GemFireCacheImpl.close(GemFireCacheImpl.java:1856)
> at com.gemstone.gemfire.internal.cache.GemFireCacheImpl.close(GemFireCacheImpl.java:1852)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)