copy list to prevent ConcurrentModificationException (#4554)

confluentinc · Feb 14, 2020 · a6dfdaa · a6dfdaa
1 parent ddf0701
commit a6dfdaa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ksql-api/src/test/java/io/confluent/ksql/api/TestInsertsSubscriber.java b/ksql-api/src/test/java/io/confluent/ksql/api/TestInsertsSubscriber.java
@@ -60,7 +60,7 @@ public void handleError(final Throwable t) {
   }
 
   public synchronized List<JsonObject> getRowsInserted() {
-    return rowsInserted;
+    return new ArrayList<>(rowsInserted);
   }
 
   public synchronized boolean isCompleted() {