diff --git a/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java b/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java index d4b63f0..a83bdaf 100644 --- a/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java +++ b/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java @@ -50,6 +50,7 @@ import java.util.Map; import java.util.Properties; import java.util.UUID; +import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.Future; import java.util.concurrent.TimeoutException; import java.util.concurrent.atomic.AtomicInteger; @@ -481,7 +482,7 @@ public void run() { final Process child = pb.start(); int childId = childIdGenerator.incrementAndGet(); - final List childErrorLog = new ArrayList(); + final List childErrorLog = new CopyOnWriteArrayList<>(); redirect("stdout-redir-" + childId, new Redirector(child.getInputStream())); redirect("stderr-redir-" + childId, new Redirector(child.getErrorStream(), childErrorLog));