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 67f2158..8ef2239 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 @@ -484,10 +484,10 @@ 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-" + threadName, new Redirector(child.getInputStream())); + redirect("stderr-redir-" + threadName, new Redirector(child.getErrorStream(), childErrorLog)); runnable = new Runnable() { @Override