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)
