You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2013/03/11 15:17:30 UTC
[1/5] git commit: Nit: fix o.a.c.hadoop.ConfigHelper to return
correct property on getThriftMaxMessageLength(Configuration)
Nit: fix o.a.c.hadoop.ConfigHelper to return correct property on getThriftMaxMessageLength(Configuration)
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/37ba434e
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/37ba434e
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/37ba434e
Branch: refs/heads/trunk
Commit: 37ba434efba9e307850711ec71b4ddc7b23d7d7a
Parents: 712d468
Author: Pavel Yaskevich <xe...@apache.org>
Authored: Sun Mar 10 15:35:51 2013 -0700
Committer: Pavel Yaskevich <xe...@apache.org>
Committed: Sun Mar 10 15:35:51 2013 -0700
----------------------------------------------------------------------
.../org/apache/cassandra/hadoop/ConfigHelper.java | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/37ba434e/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hadoop/ConfigHelper.java b/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
index ad29903..9adc545 100644
--- a/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
+++ b/src/java/org/apache/cassandra/hadoop/ConfigHelper.java
@@ -493,7 +493,7 @@ public class ConfigHelper
*/
public static int getThriftMaxMessageLength(Configuration conf)
{
- return conf.getInt(THRIFT_FRAMED_TRANSPORT_SIZE_IN_MB, 16) * 1024 * 1024; // 16MB is default in Cassandra
+ return conf.getInt(THRIFT_MAX_MESSAGE_LENGTH_IN_MB, 16) * 1024 * 1024; // 16MB is default in Cassandra
}
public static CompressionParameters getOutputCompressionParamaters(Configuration conf)