hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aihu...@apache.org
Subject hive git commit: HIVE-13530: Hive on Spark throws Kryo exception in some cases (Szehon Ho, reviewed by Aihua Xu)
Date Wed, 11 May 2016 20:49:53 GMT
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 <aihuaxu@apache.org>
Authored: Wed May 11 16:48:44 2016 -0400
Committer: Aihua Xu <aihuaxu@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;


Mime
View raw message