MergePolicyCustomTest - Inbound transfer was cancelled

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]