commit 37eb13cea67b3f087ddd6a22e283fdd3e4e883a9 Author: Dan Burkert Date: Tue Jun 12 15:42:20 2018 -0700 Inline TDeserializer in JSONMessageFactory diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/messaging/json/JSONMessageFactory.java b/metastore/src/java/org/apache/hadoop/hive/metastore/messaging/json/JSONMessageFactory.java index 9b381ff494..e03a8ccee4 100644 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/messaging/json/JSONMessageFactory.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/messaging/json/JSONMessageFactory.java @@ -77,7 +77,6 @@ private static final Logger LOG = LoggerFactory.getLogger(JSONMessageFactory.class.getName()); private static JSONMessageDeserializer deserializer = new JSONMessageDeserializer(); - private static TDeserializer thriftDeSerializer = new TDeserializer(new TJSONProtocol.Factory()); @Override public MessageDeserializer getDeserializer() { @@ -267,7 +266,7 @@ public static Table getTableObj(ObjectNode jsonTree) throws Exception { public static TBase getTObj(String tSerialized, Class objClass) throws Exception{ TBase obj = objClass.newInstance(); - thriftDeSerializer.deserialize(obj, tSerialized, "UTF-8"); + new TDeserializer(new TJSONProtocol.Factory()).deserialize(obj, tSerialized, "UTF-8"); return obj; }