Repository: hive Updated Branches: refs/heads/branch-3 93e6e36bf -> 530a68ad5
HIVE-20116: TezTask is using parent logger (Prasanth Jayachandran reviewed by Sergey Shelukhin) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/530a68ad Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/530a68ad Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/530a68ad Branch: refs/heads/branch-3 Commit: 530a68ad50b9ecbad26ba3b926ee370eac3838d8 Parents: 93e6e36 Author: Prasanth Jayachandran <prasan...@apache.org> Authored: Tue Jul 17 11:11:56 2018 -0700 Committer: Prasanth Jayachandran <prasan...@apache.org> Committed: Tue Jul 17 11:12:15 2018 -0700 ---------------------------------------------------------------------- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java | 4 ++++ .../java/org/apache/hadoop/hive/ql/log/LogDivertAppender.java | 6 ++++-- 2 files changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/530a68ad/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java index a15482f..f2ed07a 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/TezTask.java @@ -84,6 +84,9 @@ import org.apache.tez.dag.api.client.DAGStatus; import org.apache.tez.dag.api.client.StatusGetOpts; import org.apache.tez.dag.api.client.VertexStatus; import org.json.JSONObject; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import com.google.common.annotations.VisibleForTesting; /** @@ -96,6 +99,7 @@ import com.google.common.annotations.VisibleForTesting; public class TezTask extends Task<TezWork> { private static final String CLASS_NAME = TezTask.class.getName(); + private static transient Logger LOG = LoggerFactory.getLogger(CLASS_NAME); private final PerfLogger perfLogger = SessionState.getPerfLogger(); private static final String TEZ_MEMORY_RESERVE_FRACTION = "tez.task.scale.memory.reserve-fraction"; http://git-wip-us.apache.org/repos/asf/hive/blob/530a68ad/ql/src/java/org/apache/hadoop/hive/ql/log/LogDivertAppender.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/log/LogDivertAppender.java b/ql/src/java/org/apache/hadoop/hive/ql/log/LogDivertAppender.java index b5e8b95..0105fd5 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/log/LogDivertAppender.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/log/LogDivertAppender.java @@ -23,6 +23,7 @@ import org.apache.hadoop.hive.common.LogUtils; import org.apache.hadoop.hive.conf.HiveConf; import org.apache.hadoop.hive.ql.Driver; import org.apache.hadoop.hive.ql.exec.Task; +import org.apache.hadoop.hive.ql.exec.tez.TezTask; import org.apache.hadoop.hive.ql.session.OperationLog; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.core.LogEvent; @@ -80,8 +81,9 @@ public class LogDivertAppender { */ private static final Pattern executionIncludeNamePattern = Pattern.compile(Joiner.on("|"). join(new String[]{"org.apache.hadoop.mapreduce.JobSubmitter", - "org.apache.hadoop.mapreduce.Job", "SessionState", "ReplState", Task.class.getName(), - Driver.class.getName(), "org.apache.hadoop.hive.ql.exec.spark.status.SparkJobMonitor"})); + "org.apache.hadoop.mapreduce.Job", "SessionState", "ReplState", Task.class.getName(), + TezTask.class.getName(), Driver.class.getName(), + "org.apache.hadoop.hive.ql.exec.spark.status.SparkJobMonitor"})); /* Patterns that are included in performance logging level. * In performance mode, show execution and performance logger messages.
