You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by su...@apache.org on 2017/01/09 05:35:14 UTC
hive git commit: HIVE-15494: Create perfLogger in method execute
instead of class initialization for SparkTask (Zhihai Xu,
reviewed by Chao Sun)
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 <zh...@gmail.com>
Authored: Sun Jan 8 21:34:49 2017 -0800
Committer: Chao Sun <su...@apache.org>
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 {