commit e7b7536595ceb4682dc853544a2103a2e49b3151 Author: Bharath Krishna Date: Tue May 22 11:06:25 2018 -0700 HIVE-19559 : SparkClientImpl shouldn't name redirector thread RemoteDriver 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 f8b5d19e7a0dd6e6cb84c53828cb9bf356cb5ecc..847c82b640154b3c04da20f8470c30f63570c53e 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 @@ -473,9 +473,9 @@ private Thread startDriver(final RpcServer rpcServer, final String clientId, fin final List childErrorLog = Collections.synchronizedList(new ArrayList()); final LogRedirector.LogSourceCallback callback = () -> {return isAlive;}; - LogRedirector.redirect("RemoteDriver-stdout-redir-" + threadName, + LogRedirector.redirect("spark-submit-stdout-redir-" + threadName, new LogRedirector(child.getInputStream(), LOG, callback)); - LogRedirector.redirect("RemoteDriver-stderr-redir-" + threadName, + LogRedirector.redirect("spark-submit-stderr-redir-" + threadName, new LogRedirector(child.getErrorStream(), LOG, childErrorLog, callback)); runnable = new Runnable() {