diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/SerializationUtilities.java ql/src/java/org/apache/hadoop/hive/ql/exec/SerializationUtilities.java index 28550d88fd..eaa8f122d2 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/SerializationUtilities.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/SerializationUtilities.java @@ -35,6 +35,7 @@ import java.util.List; import java.util.Map; import java.util.Properties; +import java.util.concurrent.atomic.AtomicReference; import org.apache.commons.codec.binary.Base64; import org.apache.commons.lang3.tuple.Pair; @@ -258,6 +259,7 @@ public Kryo create() { kryo.register(SparkWork.class); kryo.register(Pair.class); kryo.register(MemoryMonitorInfo.class); + kryo.register(AtomicReference.class); // This must be called after all the explicit register calls. return kryo.processHooks(kryoTypeHooks, globalHook);