You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@geode.apache.org by "Eric Shu (Jira)" <ji...@apache.org> on 2019/12/03 23:42:00 UTC
[jira] [Assigned] (GEODE-7530) For AEQ queue size, GEODE should
return local size only
[ https://issues.apache.org/jira/browse/GEODE-7530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Eric Shu reassigned GEODE-7530:
-------------------------------
Assignee: Eric Shu
> For AEQ queue size, GEODE should return local size only
> --------------------------------------------------------
>
> Key: GEODE-7530
> URL: https://issues.apache.org/jira/browse/GEODE-7530
> Project: Geode
> Issue Type: Bug
> Components: wan
> Reporter: Eric Shu
> Assignee: Eric Shu
> Priority: Major
>
> The following stack shows that current it does not.
> {noformat}
> [warn 2019/11/24 19:48:51.755 PST <ThreadsMonitor> tid=0x1f] Thread <96> (0x60) that was executed at <24 Nov 2019 19:47:30 PST> has been stuck for <81.69 seconds> and number of thread monitor iteration <1>
> Thread Name <Event Processor for GatewaySender_AsyncEventQueue_index#_testRegion_0> state <TIMED_WAITING>
> Waiting on <ja...@607baea6>
> Executor Group <GatewaySenderEventProcessor>
> Monitored metric <ResourceManagerStats.numThreadsStuck>
> Thread stack:
> sun.misc.Unsafe.park(Native Method)
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
> java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037)
> java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328)
> java.util.concurrent.CountDownLatch.await(CountDownLatch.java:277)
> org.apache.geode.internal.util.concurrent.StoppableCountDownLatch.await(StoppableCountDownLatch.java:72)
> org.apache.geode.distributed.internal.ReplyProcessor21.basicWait(ReplyProcessor21.java:731)
> org.apache.geode.distributed.internal.ReplyProcessor21.waitForRepliesUninterruptibly(ReplyProcessor21.java:802)
> org.apache.geode.distributed.internal.ReplyProcessor21.waitForRepliesUninterruptibly(ReplyProcessor21.java:779)
> org.apache.geode.distributed.internal.ReplyProcessor21.waitForRepliesUninterruptibly(ReplyProcessor21.java:865)
> org.apache.geode.internal.cache.partitioned.SizeMessage$SizeResponse.waitBucketSizes(SizeMessage.java:344)
> org.apache.geode.internal.cache.PartitionedRegion.getSizeRemotely(PartitionedRegion.java:6718)
> org.apache.geode.internal.cache.PartitionedRegion.entryCount(PartitionedRegion.java:6669)
> org.apache.geode.internal.cache.PartitionedRegion.entryCount(PartitionedRegion.java:6651)
> org.apache.geode.internal.cache.PartitionedRegion.getRegionSize(PartitionedRegion.java:6623)
> org.apache.geode.internal.cache.LocalRegionDataView.entryCount(LocalRegionDataView.java:99)
> org.apache.geode.internal.cache.LocalRegion.entryCount(LocalRegion.java:2078)
> org.apache.geode.internal.cache.LocalRegion.size(LocalRegion.java:8262)
> org.apache.geode.internal.cache.wan.parallel.ParallelGatewaySenderQueue.size(ParallelGatewaySenderQueue.java:1502)
> org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor.eventQueueSize(AbstractGatewaySenderEventProcessor.java:271)
> org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor.handleSuccessfulBatchDispatch(AbstractGatewaySenderEventProcessor.java:969)
> org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor.processQueue(AbstractGatewaySenderEventProcessor.java:667)
> org.apache.geode.internal.cache.wan.AbstractGatewaySenderEventProcessor.run(AbstractGatewaySenderEventProcessor.java:1111)
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)