diff --git spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java index c4495a9..6fb20b2 100644 --- spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java +++ spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java @@ -482,9 +482,11 @@ public void run() { final Process child = pb.start(); int childId = childIdGenerator.incrementAndGet(); + String threadName = Thread.currentThread().getName(); final List childErrorLog = Collections.synchronizedList(new ArrayList()); - redirect("stdout-redir-" + childId, new Redirector(child.getInputStream())); - redirect("stderr-redir-" + childId, new Redirector(child.getErrorStream(), childErrorLog)); + redirect("stdout-redir-" + childId + "-" + threadName, new Redirector(child.getInputStream())); + redirect("stderr-redir-" + childId + "-" + threadName, + new Redirector(child.getErrorStream(), childErrorLog)); runnable = new Runnable() { @Override