diff --git metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index 2547da7..8404d03 100644 --- metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@ -201,7 +201,7 @@ import org.apache.hadoop.util.StringUtils; import org.apache.thrift.TException; import org.apache.thrift.TProcessor; -import org.apache.thrift.protocol.TBinaryProtocol; +import org.apache.thrift.protocol.TCompactProtocol; import org.apache.thrift.server.TServer; import org.apache.thrift.server.TThreadPoolServer; import org.apache.thrift.transport.TFramedTransport; @@ -5844,9 +5844,9 @@ public static void startMetaStore(int port, HadoopThriftAuthBridge bridge, TThreadPoolServer.Args args = new TThreadPoolServer.Args(serverTransport) .processor(processor) .transportFactory(transFactory) - .protocolFactory(new TBinaryProtocol.Factory()) + .protocolFactory(new TCompactProtocol.Factory()) .inputProtocolFactory( - new TBinaryProtocol.Factory(true, true, maxMessageSize, maxMessageSize)) + new TCompactProtocol.Factory(maxMessageSize, maxMessageSize)) .minWorkerThreads(minWorkerThreads) .maxWorkerThreads(maxWorkerThreads); diff --git metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java index 4ebf987..ed7f9d6 100644 --- metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java +++ metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java @@ -131,7 +131,7 @@ import org.apache.hadoop.util.StringUtils; import org.apache.thrift.TApplicationException; import org.apache.thrift.TException; -import org.apache.thrift.protocol.TBinaryProtocol; +import org.apache.thrift.protocol.TCompactProtocol; import org.apache.thrift.transport.TFramedTransport; import org.apache.thrift.transport.TSocket; import org.apache.thrift.transport.TTransport; @@ -387,7 +387,7 @@ private void open() throws MetaException { transport = new TFramedTransport(transport); } - client = new ThriftHiveMetastore.Client(new TBinaryProtocol(transport)); + client = new ThriftHiveMetastore.Client(new TCompactProtocol(transport)); try { transport.open(); isConnected = true;