Repository: hive Updated Branches: refs/heads/master 1d23ea8d0 -> 6fdf49ac2
HIVE-15494: Create perfLogger in method execute instead of class initialization for SparkTask (Zhihai Xu, reviewed by Chao Sun) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/6fdf49ac Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/6fdf49ac Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/6fdf49ac Branch: refs/heads/master Commit: 6fdf49ac24bbc45aaa1f99ccf3d7462f8335c8ec Parents: 1d23ea8 Author: Zhihai Xu <[email protected]> Authored: Sun Jan 8 21:34:49 2017 -0800 Committer: Chao Sun <[email protected]> Committed: Sun Jan 8 21:34:49 2017 -0800 ---------------------------------------------------------------------- ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/6fdf49ac/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java index 87d80a3..2a0aeda 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/spark/SparkTask.java @@ -72,7 +72,7 @@ public class SparkTask extends Task<SparkWork> { private static final String CLASS_NAME = SparkTask.class.getName(); private static final Logger LOG = LoggerFactory.getLogger(CLASS_NAME); private static final LogHelper console = new LogHelper(LOG); - private final PerfLogger perfLogger = SessionState.getPerfLogger(); + private PerfLogger perfLogger; private static final long serialVersionUID = 1L; private transient String sparkJobID; private transient SparkStatistics sparkStatistics; @@ -94,6 +94,7 @@ public class SparkTask extends Task<SparkWork> { public int execute(DriverContext driverContext) { int rc = 0; + perfLogger = SessionState.getPerfLogger(); SparkSession sparkSession = null; SparkSessionManager sparkSessionManager = null; try {
