diff --git metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index 25b61a7..c7ce4fd 100644 --- metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@ -5826,7 +5826,8 @@ public static void startMetaStore(int port, HadoopThriftAuthBridge bridge, .processor(processor) .transportFactory(transFactory) .protocolFactory(new TBinaryProtocol.Factory()) - .inputProtocolFactory(new TBinaryProtocol.Factory(true, true, maxMessageSize)) + .inputProtocolFactory( + new TBinaryProtocol.Factory(true, true, maxMessageSize, maxMessageSize)) .minWorkerThreads(minWorkerThreads) .maxWorkerThreads(maxWorkerThreads); diff --git pom.xml pom.xml index 2156fec..ba6fa92 100644 --- pom.xml +++ pom.xml @@ -138,8 +138,8 @@ 20090211 4.11 2.22 - 0.9.0 - 0.9.0 + 0.9.2 + 0.9.2 1.2.16 2.3 1.9.5 diff --git service/src/java/org/apache/hive/service/cli/thrift/ThriftBinaryCLIService.java service/src/java/org/apache/hive/service/cli/thrift/ThriftBinaryCLIService.java index dc68efb..3c58453 100644 --- service/src/java/org/apache/hive/service/cli/thrift/ThriftBinaryCLIService.java +++ service/src/java/org/apache/hive/service/cli/thrift/ThriftBinaryCLIService.java @@ -81,7 +81,7 @@ public void run() { TThreadPoolServer.Args sargs = new TThreadPoolServer.Args(serverSocket) .processorFactory(processorFactory).transportFactory(transportFactory) .protocolFactory(new TBinaryProtocol.Factory()) - .inputProtocolFactory(new TBinaryProtocol.Factory(true, true, maxMessageSize)) + .inputProtocolFactory(new TBinaryProtocol.Factory(true, true, maxMessageSize, maxMessageSize)) .executorService(executorService); // TCP Server diff --git shims/common/pom.xml shims/common/pom.xml index f8d779d..7d0186f 100644 --- shims/common/pom.xml +++ shims/common/pom.xml @@ -57,6 +57,11 @@ true + commons-lang + commons-lang + ${commons-lang.version} + + org.apache.thrift libthrift ${libthrift.version}