You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@geode.apache.org by Mark Bretl <mb...@apache.org> on 2017/10/27 17:23:51 UTC

Re: need suggestion about below exception

+ user

On Fri, Oct 27, 2017 at 9:37 AM, dinesh 1004 <di...@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 <di...@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>
> >
>