Author: ecn Date: Mon Apr 8 13:21:06 2013 New Revision: 1465625 URL: http://svn.apache.org/r1465625 Log: ACCUMULO-1251 applying Adam Fuch's patch to allow clients to recieve large messages
Modified: accumulo/branches/1.5/core/src/main/java/org/apache/accumulo/core/util/ThriftUtil.java Modified: accumulo/branches/1.5/core/src/main/java/org/apache/accumulo/core/util/ThriftUtil.java URL: http://svn.apache.org/viewvc/accumulo/branches/1.5/core/src/main/java/org/apache/accumulo/core/util/ThriftUtil.java?rev=1465625&r1=1465624&r2=1465625&view=diff ============================================================================== --- accumulo/branches/1.5/core/src/main/java/org/apache/accumulo/core/util/ThriftUtil.java (original) +++ accumulo/branches/1.5/core/src/main/java/org/apache/accumulo/core/util/ThriftUtil.java Mon Apr 8 13:21:06 2013 @@ -80,7 +80,7 @@ public class ThriftUtil { } static private TProtocolFactory protocolFactory = new TraceProtocolFactory(); - static private TTransportFactory transportFactory = new TFramedTransport.Factory(); + static private TTransportFactory transportFactory = new TFramedTransport.Factory(Integer.MAX_VALUE); static public <T extends TServiceClient> T createClient(TServiceClientFactory<T> factory, TTransport transport) { return factory.getClient(protocolFactory.getProtocol(transport), protocolFactory.getProtocol(transport));