You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ai...@apache.org on 2016/05/11 20:49:53 UTC
hive git commit: HIVE-13530: Hive on Spark throws Kryo exception in
some cases (Szehon Ho, reviewed by Aihua Xu)
Repository: hive
Updated Branches:
refs/heads/master b36f6a3a2 -> ece8226b6
HIVE-13530: Hive on Spark throws Kryo exception in some cases (Szehon Ho, reviewed by Aihua Xu)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/ece8226b
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/ece8226b
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/ece8226b
Branch: refs/heads/master
Commit: ece8226b60100b873f2beaee13f5df5f66a207a5
Parents: b36f6a3
Author: Aihua Xu <ai...@apache.org>
Authored: Wed May 11 16:48:44 2016 -0400
Committer: Aihua Xu <ai...@apache.org>
Committed: Wed May 11 16:48:44 2016 -0400
----------------------------------------------------------------------
.../org/apache/hadoop/hive/ql/exec/SparkHashTableSinkOperator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/ece8226b/ql/src/java/org/apache/hadoop/hive/ql/exec/SparkHashTableSinkOperator.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/SparkHashTableSinkOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/SparkHashTableSinkOperator.java
index 523ff7c..3b358ee 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/SparkHashTableSinkOperator.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/SparkHashTableSinkOperator.java
@@ -47,7 +47,7 @@ public class SparkHashTableSinkOperator
extends TerminalOperator<SparkHashTableSinkDesc> implements Serializable {
private static final long serialVersionUID = 1L;
private final String CLASS_NAME = this.getClass().getName();
- private final PerfLogger perfLogger = SessionState.getPerfLogger();
+ private final transient PerfLogger perfLogger = SessionState.getPerfLogger();
protected static final Logger LOG = LoggerFactory.getLogger(SparkHashTableSinkOperator.class.getName());
public static final String DFS_REPLICATION_MAX = "dfs.replication.max";
private int minReplication = 10;