[
https://issues.apache.org/jira/browse/GEODE-4219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Huynh resolved GEODE-4219.
--------------------------------
Resolution: Fixed
Assignee: Jason Huynh
Test was not currently being run depending on whether the static field toCnt
was set in another test or not.
Modified test to guarantee operations occur before continuing test - instead of
an arbitrary "fingers-crossed" wait.
The listener will no longer apply puts into the region if the test is shutting
down.
> CI suspect string: java.lang.AssertionError: The put operation in queue did
> not succeed due to CacheClosedException
> --------------------------------------------------------------------------------------------------------------------
>
> Key: GEODE-4219
> URL: https://issues.apache.org/jira/browse/GEODE-4219
> Project: Geode
> Issue Type: Bug
> Components: client queues
> Affects Versions: 1.4.0
> Reporter: Shelley Lynn Hughes-Godfrey
> Assignee: Jason Huynh
> Priority: Major
> Labels: pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> This suspect string was seen during CI:
> https://concourse.apachegeode-ci.info/teams/main/pipelines/develop/jobs/DistributedTest/builds/60
> {noformat}
> org.apache.geode.internal.cache.ha.HARegionQueueDUnitTest >
> testConcurrentOperationsDunitTestOnNonBlockingQueueWithDNoAckRegion FAILED
> java.lang.AssertionError: Suspicious strings were written to the log
> during this run.
> Fix the strings or use IgnoredException.addIgnoredException to ignore.
> -----------------------------------------------------------------------
> Found suspect string in log4j at line 2338
> [error 2018/01/04 20:20:27.909 UTC <P2P message reader for
> 172.17.0.3(164)<v46>:32773 shared ordered uid=9 port=47318> tid=0x2a6]
> Exception occurred in CacheListener
> java.lang.AssertionError: The put operation in queue did not succeed due
> to exception =
> at org.apache.geode.test.dunit.Assert.fail(Assert.java:66)
> at
> org.apache.geode.internal.cache.ha.HARegionQueueDUnitTest$6$1.afterUpdate(HARegionQueueDUnitTest.java:602)
> at
> org.apache.geode.internal.cache.EnumListenerEvent$AFTER_UPDATE.dispatchEvent(EnumListenerEvent.java:119)
> at
> org.apache.geode.internal.cache.LocalRegion.dispatchEvent(LocalRegion.java:8450)
> at
> org.apache.geode.internal.cache.LocalRegion.dispatchListenerEvent(LocalRegion.java:6953)
> at
> org.apache.geode.internal.cache.LocalRegion.invokePutCallbacks(LocalRegion.java:5926)
> at
> org.apache.geode.internal.cache.EntryEventImpl.invokeCallbacks(EntryEventImpl.java:2339)
> at
> org.apache.geode.internal.cache.entries.AbstractRegionEntry.dispatchListenerEvents(AbstractRegionEntry.java:171)
> at
> org.apache.geode.internal.cache.LocalRegion.basicPutPart2(LocalRegion.java:5784)
> at
> org.apache.geode.internal.cache.AbstractRegionMap.basicPut(AbstractRegionMap.java:2864)
> at
> org.apache.geode.internal.cache.LocalRegion.virtualPut(LocalRegion.java:5622)
> at
> org.apache.geode.internal.cache.DistributedRegion.virtualPut(DistributedRegion.java:369)
> at
> org.apache.geode.internal.cache.LocalRegionDataView.putEntry(LocalRegionDataView.java:152)
> at
> org.apache.geode.internal.cache.LocalRegion.basicUpdate(LocalRegion.java:5603)
> at
> org.apache.geode.internal.cache.AbstractUpdateOperation.doPutOrCreate(AbstractUpdateOperation.java:165)
> at
> org.apache.geode.internal.cache.AbstractUpdateOperation$AbstractUpdateMessage.basicOperateOnRegion(AbstractUpdateOperation.java:272)
> at
> org.apache.geode.internal.cache.AbstractUpdateOperation$AbstractUpdateMessage.operateOnRegion(AbstractUpdateOperation.java:243)
> at
> org.apache.geode.internal.cache.DistributedCacheOperation$CacheOperationMessage.basicProcess(DistributedCacheOperation.java:1189)
> at
> org.apache.geode.internal.cache.DistributedCacheOperation$CacheOperationMessage.process(DistributedCacheOperation.java:1090)
> at
> org.apache.geode.distributed.internal.DistributionMessage.scheduleAction(DistributionMessage.java:382)
> at
> org.apache.geode.distributed.internal.DistributionMessage.schedule(DistributionMessage.java:440)
> at
> org.apache.geode.distributed.internal.DistributionManager.scheduleIncomingMessage(DistributionManager.java:3209)
> at
> org.apache.geode.distributed.internal.DistributionManager.handleIncomingDMsg(DistributionManager.java:2871)
> at
> org.apache.geode.distributed.internal.DistributionManager.access$1500(DistributionManager.java:108)
> at
> org.apache.geode.distributed.internal.DistributionManager$DMListener.messageReceived(DistributionManager.java:3987)
> at
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManager.dispatchMessage(GMSMembershipManager.java:1127)
> at
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManager.handleOrDeferMessage(GMSMembershipManager.java:1045)
> at
> org.apache.geode.distributed.internal.membership.gms.mgr.GMSMembershipManager$MyDCReceiver.messageReceived(GMSMembershipManager.java:408)
> at
> org.apache.geode.distributed.internal.direct.DirectChannel.receive(DirectChannel.java:715)
> at
> org.apache.geode.internal.tcp.TCPConduit.messageReceived(TCPConduit.java:875)
> at
> org.apache.geode.internal.tcp.Connection.dispatchMessage(Connection.java:3967)
> at
> org.apache.geode.internal.tcp.Connection.processNIOBuffer(Connection.java:3553)
> at
> org.apache.geode.internal.tcp.Connection.runNioReader(Connection.java:1829)
> at org.apache.geode.internal.tcp.Connection.run(Connection.java:1690)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: org.apache.geode.cache.CacheClosedException: The cache is
> closed.
> at
> org.apache.geode.internal.cache.GemFireCacheImpl$Stopper.generateCancelledException(GemFireCacheImpl.java:1536)
> at
> org.apache.geode.internal.cache.LocalRegion$Stopper.generateCancelledException(LocalRegion.java:506)
> at
> org.apache.geode.CancelCriterion.checkCancelInProgress(CancelCriterion.java:83)
> at
> org.apache.geode.internal.util.concurrent.StoppableReentrantReadWriteLock$StoppableWriteLock.lockInterruptibly(StoppableReentrantReadWriteLock.java:204)
> at
> org.apache.geode.internal.util.concurrent.StoppableReentrantReadWriteLock$StoppableWriteLock.lock(StoppableReentrantReadWriteLock.java:187)
> at
> org.apache.geode.internal.cache.ha.HARegionQueue.acquireWriteLock(HARegionQueue.java:1819)
> at
> org.apache.geode.internal.cache.ha.HARegionQueue.publish(HARegionQueue.java:1017)
> at
> org.apache.geode.internal.cache.ha.HARegionQueue$DispatchedAndCurrentEvents.putObject(HARegionQueue.java:2938)
> at
> org.apache.geode.internal.cache.ha.HARegionQueue.basicPut(HARegionQueue.java:650)
> at
> org.apache.geode.internal.cache.ha.HARegionQueue.put(HARegionQueue.java:602)
> at
> org.apache.geode.internal.cache.ha.HARegionQueueDUnitTest$6$1.afterUpdate(HARegionQueueDUnitTest.java:600)
> ... 33 more
> {noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
