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 b24d1e392b..90d6c9cbd9 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 @@ -76,7 +76,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() { @@ -247,12 +246,12 @@ public static Table getTableObj(ObjectNode jsonTree) throws Exception { */ public static TBase getTObj(String tSerialized, Class objClass) throws Exception{ + TDeserializer thriftDeSerializer = new TDeserializer(new TJSONProtocol.Factory()); TBase obj = objClass.newInstance(); thriftDeSerializer.deserialize(obj, tSerialized, "UTF-8"); return obj; } - public static Iterable getTObjs( Iterable objRefStrs, final Class objClass) throws Exception {