accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [1/6] git commit: ACCUMULO-2658 Don't read more than the configured maximum amount of data for the proxy thrift server
Date Thu, 26 Jun 2014 22:38:35 GMT
Repository: accumulo
Updated Branches:
  refs/heads/1.5.2-SNAPSHOT e01a72062 -> 727bbf713
  refs/heads/1.6.1-SNAPSHOT 2a17a7a2b -> c8b788189
  refs/heads/master ab6ea922f -> f295f8fe5


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/1.5.2-SNAPSHOT
Commit: 727bbf7130766f85e56efe4b19f8c0ea56369c16
Parents: e01a720
Author: Josh Elser <elserj@apache.org>
Authored: Thu Jun 26 18:20:39 2014 -0400
Committer: Josh Elser <elserj@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);
   }
 }


Mime
View raw message