Repository: hive Updated Branches: refs/heads/master 92dd70739 -> 68a2beabc
HIVE-19559: SparkClientImpl shouldn't name redirector thread RemoteDriver (Bharathkrishna Guruvayoor Murali, reviewed by Sahil Takiar) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/68a2beab Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/68a2beab Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/68a2beab Branch: refs/heads/master Commit: 68a2beabc38944c3e5238b454b1a0fe30dbf0034 Parents: 92dd707 Author: Bharathkrishna Guruvayoor Murali <bhar...@cloudera.com> Authored: Thu May 24 13:40:36 2018 -0700 Committer: Sahil Takiar <stak...@cloudera.com> Committed: Thu May 24 13:40:36 2018 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/hive/spark/client/SparkClientImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/68a2beab/spark-client/src/main/java/org/apache/hive/spark/client/SparkClientImpl.java ---------------------------------------------------------------------- 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 f8b5d19..847c82b 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 @@ -473,9 +473,9 @@ class SparkClientImpl implements SparkClient { final List<String> childErrorLog = Collections.synchronizedList(new ArrayList<String>()); 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() {
