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 <aihu...@apache.org> Authored: Wed May 11 16:48:44 2016 -0400 Committer: Aihua Xu <aihu...@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;