+ user On Fri, Oct 27, 2017 at 9:37 AM, dinesh 1004 <dineshpune2...@gmail.com> wrote:
> Hi All, > Is there any geode test class which populate data in > *ParallelGatewaySenderQueue > and create some back log. * > Insert/remove operation i can test. > > Thanks, > Dinesh Akhand > > On Fri, Oct 27, 2017 at 9:24 PM, Dinesh Akhand <dines...@amdocs.com> > wrote: > > > Any one suggest about below exception: > > > > at org.apache.geode.internal.cache.DiskEntry$Helper. > > removeFromDisk(DiskEntry.java:1505) > > at org.apache.geode.internal.cache.AbstractOplogDiskRegionEntry. > > removePhase1(AbstractOplogDiskRegionEntry.java:42) > > at org.apache.geode.internal.cache.AbstractRegionEntry. > > destroy(AbstractRegionEntry.java:896) > > at org.apache.geode.internal.cache.AbstractRegionMap. > destroyEntry( > > AbstractRegionMap.java:3084) > > at org.apache.geode.internal.cache.AbstractRegionMap. > > destroy(AbstractRegionMap.java:1422) > > at org.apache.geode.internal.cache.LocalRegion.mapDestroy( > > LocalRegion.java:6566) > > at org.apache.geode.internal.cache.LocalRegion.mapDestroy( > > LocalRegion.java:6540) > > at org.apache.geode.internal.cache.BucketRegion. > > basicDestroy(BucketRegion.java:1183) > > at org.apache.geode.internal.cache.AbstractBucketRegionQueue. > > basicDestroy(AbstractBucketRegionQueue.java:352) > > at org.apache.geode.internal.cache.BucketRegionQueue. > basicDestroy( > > BucketRegionQueue.java:363) > > at org.apache.geode.internal.cache.LocalRegion. > > validatedDestroy(LocalRegion.java:1111) > > at org.apache.geode.internal.cache.DistributedRegion. > > validatedDestroy(DistributedRegion.java:904) > > at org.apache.geode.internal.cache.LocalRegion.destroy( > > LocalRegion.java:1096) > > at org.apache.geode.internal.cache.AbstractRegion.destroy( > > AbstractRegion.java:315) > > at org.apache.geode.internal.cache.LocalRegion.remove( > > LocalRegion.java:8976) > > at org.apache.geode.internal.cache.wan.parallel. > > ParallelGatewaySenderQueue.clearPartitionedRegion( > > ParallelGatewaySenderQueue.java:1830) > > at org.apache.geode.internal.cache.wan.parallel. > > ParallelGatewaySenderQueue.clearQueue(ParallelGatewaySenderQueue. > > java:1800) > > at org.apache.geode.internal.cache.wan.parallel. > > ConcurrentParallelGatewaySenderQueue.clearQueue( > > ConcurrentParallelGatewaySenderQueue.java:237) > > at org.apa > > > > In geode 1.1 Clear queue function is working correctly for us. > > But with same configuration in geode 1.2 is not working. > > > > I tried to add the debug log and printed disk region which is created > > inside the LocalRegion.java, diskregion is not null. > > > > [info 2017/10/27 12:26:43.196 IDT eaasrt-server1 <Pooled Waiting Message > > Processor 3> tid=0xf2] akhand diskregion/__PR/_B__AsyncEventQueue > > __PWInfoQueue__PARALLEL__GATEWAY__SENDER__QUEUE_4fullpath:=/__PR/_B__ > > AsyncEventQueue__PWInfoQueue__PARALLEL__GATEWAY__SENDER__QUEUE_4isuse > > > > Which is not Null , also DiskStoreImpl is Not null > > > > info 2017/10/27 13:59:36.407 IDT eaasrt-server1 <Pooled Waiting Message > > Processor 2> tid=0xe8] akhand diskregion/__PR/_B__AsyncEventQueue > > __PWInfoQueue__PARALLEL__GATEWAY__SENDER__QUEUE_109fullpath:=/__PR/_B__ > > AsyncEventQueue__PWInfoQueue__PARALLEL__GATEWAY__SENDER__QUEUE_109i > > suse:false,dsi:PWInfo-queue-overflow > > > > Thanks, > > Dinesh Akhand > > This message and the information contained herein is proprietary and > > confidential and subject to the Amdocs policy statement, > > > > you may review at https://www.amdocs.com/about/email-disclaimer < > > https://www.amdocs.com/about/email-disclaimer> > > >
