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 @@ extends TerminalOperator 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;