ISPN-9501 AbstractCacheStream.performOperationRehashAware() can hang

infinispan · Sep 11, 2018 · a446799 · a446799
1 parent 1703fcd
commit a446799
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/java/org/infinispan/stream/impl/AbstractCacheStream.java b/core/src/main/java/org/infinispan/stream/impl/AbstractCacheStream.java
@@ -320,7 +320,7 @@ <R> R performOperationRehashAware(Function<? super S2, ? extends R> function, bo
             csm.forgetOperation(id);
          }
          if (!remoteResults.lostSegments.isEmpty()) {
-            segmentsToProcess = remoteResults.lostSegments;
+            segmentsToProcess = IntSets.mutableCopyFrom(remoteResults.lostSegments);
             remoteResults.lostSegments.clear();
             getLog().tracef("Found %s lost segments for identifier %s", segmentsToProcess, id);
             try {