Uploaded image for project: 'Infinispan'
  1. Infinispan
  2. ISPN-14084

MergePolicyCustomTest - Inbound transfer was cancelled

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 14.0.0.Final
    • 14.0.0.Final
    • Core, State Transfer
    • None

      org.infinispan.conflict.impl.MergePolicyCustomTest

      • testPartitionMergePolicy[REPL_SYNC, ALLOW_READ_WRITES, 2N]
        Caused by: java.util.concurrent.CancellationException: Inbound transfer was cancelled
        

        StackTrace

              org.infinispan.commons.CacheException: java.util.concurrent.CancellationException: Inbound transfer was cancelled
        	at org.infinispan.conflict.impl.DefaultConflictManager$ReplicaSpliterator.tryAdvance(DefaultConflictManager.java:511)
        	at java.base/java.util.Spliterator.forEachRemaining(Spliterator.java:326)
        	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
        	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
        	at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913)
        	at java.base/java.util.stream.ReduceOps$5.evaluateSequential(ReduceOps.java:257)
        	at java.base/java.util.stream.ReduceOps$5.evaluateSequential(ReduceOps.java:248)
        	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
        	at java.base/java.util.stream.ReferencePipeline.count(ReferencePipeline.java:605)
        	at org.infinispan.conflict.impl.BaseMergePolicyTest.afterConflictResolutionAndMerge(BaseMergePolicyTest.java:121)
        	at org.infinispan.conflict.impl.BaseMergePolicyTest.testPartitionMergePolicy(BaseMergePolicyTest.java:139)
        	at org.infinispan.commons.test.TestNGLongTestsHook.run(TestNGLongTestsHook.java:24)
        	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
        	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        	at java.base/java.lang.Thread.run(Thread.java:829)
        Caused by: java.util.concurrent.CancellationException: Inbound transfer was cancelled
        	at org.infinispan.statetransfer.InboundTransferTask.notifyCompletion(InboundTransferTask.java:268)
        	at org.infinispan.statetransfer.InboundTransferTask.cancel(InboundTransferTask.java:227)
        	at org.infinispan.conflict.impl.StateReceiverImpl$SegmentRequest.lambda$cancel$5(StateReceiverImpl.java:248)
        	at java.base/java.util.concurrent.ConcurrentHashMap.forEach(ConcurrentHashMap.java:1603)
        	at org.infinispan.conflict.impl.StateReceiverImpl$SegmentRequest.cancel(StateReceiverImpl.java:248)
        	at org.infinispan.conflict.impl.StateReceiverImpl.onDataRehash(StateReceiverImpl.java:91)
        	at org.infinispan.notifications.impl.AbstractListenerImpl$ListenerInvocationImpl.lambda$invoke$1(AbstractListenerImpl.java:453)
        	at org.infinispan.notifications.impl.AbstractListenerImpl$ListenerInvocationImpl.invoke(AbstractListenerImpl.java:479)
        	at org.infinispan.notifications.cachelistener.CacheNotifierImpl$BaseCacheEntryListenerInvocation.doRealInvocation(CacheNotifierImpl.java:1793)
        	at org.infinispan.notifications.cachelistener.CacheNotifierImpl$BaseCacheEntryListenerInvocation.invoke(CacheNotifierImpl.java:1740)
        	at org.infinispan.notifications.cachelistener.CacheNotifierImpl$BaseCacheEntryListenerInvocation.invoke(CacheNotifierImpl.java:1691)
        	at org.infinispan.notifications.cachelistener.CacheNotifierImpl.doNotifyDataRehashed(CacheNotifierImpl.java:840)
        	at org.infinispan.notifications.cachelistener.CacheNotifierImpl.notifyDataRehashed(CacheNotifierImpl.java:823)
        	at org.infinispan.statetransfer.StateConsumerImpl.onTopologyUpdate(StateConsumerImpl.java:316)
        	at org.infinispan.statetransfer.StateTransferManagerImpl.updateProviderAndConsumer(StateTransferManagerImpl.java:197)
        	at org.infinispan.statetransfer.StateTransferManagerImpl.lambda$doTopologyUpdate$0(StateTransferManagerImpl.java:184)
        	at java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106)
        	at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235)
        	at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143)
        	at org.infinispan.statetransfer.StateTransferManagerImpl.doTopologyUpdate(StateTransferManagerImpl.java:183)
        	at org.infinispan.statetransfer.StateTransferManagerImpl$1.rebalance(StateTransferManagerImpl.java:119)
        	at org.infinispan.topology.LocalTopologyManagerImpl.lambda$doHandleRebalance$19(LocalTopologyManagerImpl.java:605)
        	at java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106)
        	at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235)
        	at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143)
        	at org.infinispan.topology.LocalTopologyManagerImpl.doHandleRebalance(LocalTopologyManagerImpl.java:601)
        	at org.infinispan.topology.LocalTopologyManagerImpl.lambda$handleRebalance$16(LocalTopologyManagerImpl.java:549)
        	at org.infinispan.topology.LocalTopologyManagerImpl.lambda$orderOnCache$24(LocalTopologyManagerImpl.java:769)
        	at org.infinispan.util.concurrent.ActionSequencer.safeNonBlockingCall(ActionSequencer.java:58)
        	at org.infinispan.util.concurrent.ActionSequencer$SequenceEntry.run(ActionSequencer.java:227)
        	at org.infinispan.util.concurrent.ActionSequencer$SequenceEntry.apply(ActionSequencer.java:220)
        	at org.infinispan.util.concurrent.ActionSequencer$SequenceEntry.apply(ActionSequencer.java:180)
        	at java.base/java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:930)
        	at java.base/java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:907)
        	at java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478)
        	... 3 more
        ... Removed 21 stack frames
            
        

      Environments: [openjdk11-rhel7]

              rh-ee-jbolina Jose Bolina
              rh-ee-jbolina Jose Bolina
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated:
                Resolved: