hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From prasan...@apache.org
Subject svn commit: r1644250 - in /hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore: HiveMetaStore.java HiveMetaStoreClient.java
Date Wed, 10 Dec 2014 00:01:23 GMT
Author: prasanthj
Date: Wed Dec 10 00:01:23 2014
New Revision: 1644250

URL: http://svn.apache.org/r1644250
Log:
HIVE-9049: Metastore should use TCompactProtocol as opposed to TBinaryProtocol (Prasanth Jayachandran
reviewed by Ashutosh Chauhan)

Modified:
    hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
    hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java

Modified: hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java?rev=1644250&r1=1644249&r2=1644250&view=diff
==============================================================================
--- hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java (original)
+++ hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java Wed
Dec 10 00:01:23 2014
@@ -201,7 +201,7 @@ import org.apache.hadoop.util.Reflection
 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 class HiveMetaStore extends Thrif
       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);
 

Modified: hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java?rev=1644250&r1=1644249&r2=1644250&view=diff
==============================================================================
--- hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
(original)
+++ hive/trunk/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
Wed Dec 10 00:01:23 2014
@@ -131,7 +131,7 @@ import org.apache.hadoop.security.UserGr
 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 @@ public class HiveMetaStoreClient impleme
             transport = new TFramedTransport(transport);
           }
 
-          client = new ThriftHiveMetastore.Client(new TBinaryProtocol(transport));
+          client = new ThriftHiveMetastore.Client(new TCompactProtocol(transport));
           try {
             transport.open();
             isConnected = true;



Mime
View raw message