From 37ba434efba9e307850711ec71b4ddc7b23d7d7a Mon Sep 17 00:00:00 2001 From: Pavel Yaskevich Date: Sun, 10 Mar 2013 15:35:51 -0700 Subject: [PATCH] Nit: fix o.a.c.hadoop.ConfigHelper to return correct property on getThriftMaxMessageLength(Configuration) --- src/java/org/apache/cassandra/hadoop/ConfigHelper.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/java/org/apache/cassandra/hadoop/ConfigHelper.java b/src/java/org/apache/cassandra/hadoop/ConfigHelper.java index ad29903502..9adc5454d6 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)