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 67f2158..e40aa6b 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 @@ -87,7 +87,6 @@ private final Map conf; private final HiveConf hiveConf; - private final AtomicInteger childIdGenerator; private final Thread driverThread; private final Map> jobs; private final Rpc driverRpc; @@ -97,7 +96,6 @@ SparkClientImpl(RpcServer rpcServer, Map conf, HiveConf hiveConf) throws IOException, SparkException { this.conf = conf; this.hiveConf = hiveConf; - this.childIdGenerator = new AtomicInteger(); this.jobs = Maps.newConcurrentMap(); String clientId = UUID.randomUUID().toString(); @@ -484,10 +482,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("RemoteDriver-stdout-redir-" + threadName, new Redirector(child.getInputStream())); + redirect("RemoteDriver-stderr-redir-" + threadName, new Redirector(child.getErrorStream(), childErrorLog)); runnable = new Runnable() { @Override