commit 6d411a54666e9132f4cf501445bf7dd17c2e81b4
author Yixing Zhang <tommykuaidlaa@gmail.com> Mon Feb 24 13:00:34 2020 -0800
committer Bharath Kumarasubramanian <bharath.kumarasubramanian@gmail.com> Mon Feb 24 13:17:31 2020 -0800
tree 9fba1637344495e85502a1933e2e1e669b1c9de9
parent 3ef1c67d9ee46aab933e659a07c7d7dd4605a815

SAMZA-2461 Fix: Concurrent Modification Exception in InMemorySystem (#1280)

samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java

diff --git a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java
index f53e0b3..f3028f9 100644
--- a/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java
+++ b/samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java
@@ -20,6 +20,7 @@
 package org.apache.samza.system.inmemory;
 
 import com.google.common.base.Preconditions;
+import com.google.common.collect.ImmutableList;
 import java.time.Instant;
 import java.util.ArrayList;
 import java.util.Collections;
@@ -199,6 +200,6 @@
       return new ArrayList<>();
     }
 
-    return messageEnvelopesForSSP.subList(startingOffset, messageEnvelopesForSSP.size());
+    return ImmutableList.copyOf(messageEnvelopesForSSP.subList(startingOffset, messageEnvelopesForSSP.size()));
   }
 }