ACCUMULO-2658 Don't read more than the configured maximum amount of data for the proxy thrift server
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/727bbf71 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/727bbf71 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/727bbf71 Branch: refs/heads/master Commit: 727bbf7130766f85e56efe4b19f8c0ea56369c16 Parents: e01a720 Author: Josh Elser <els...@apache.org> Authored: Thu Jun 26 18:20:39 2014 -0400 Committer: Josh Elser <els...@apache.org> Committed: Thu Jun 26 18:21:36 2014 -0400 ---------------------------------------------------------------------- proxy/src/main/java/org/apache/accumulo/proxy/Proxy.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/727bbf71/proxy/src/main/java/org/apache/accumulo/proxy/Proxy.java ---------------------------------------------------------------------- diff --git a/proxy/src/main/java/org/apache/accumulo/proxy/Proxy.java b/proxy/src/main/java/org/apache/accumulo/proxy/Proxy.java index f6744b6..7b0a1ed 100644 --- a/proxy/src/main/java/org/apache/accumulo/proxy/Proxy.java +++ b/proxy/src/main/java/org/apache/accumulo/proxy/Proxy.java @@ -141,6 +141,7 @@ public class Proxy { throw new RuntimeException(maxFrameSize + " is larger than MAX_INT"); args.transportFactory(new TFramedTransport.Factory((int)maxFrameSize)); args.protocolFactory(protoClass.newInstance()); + args.maxReadBufferBytes = maxFrameSize; return new THsHaServer(args); } }
