Nit: fix o.a.c.hadoop.ConfigHelper to return correct property on getThriftMaxMessageLength(Configuration)

This commit is contained in:
Pavel Yaskevich 2013-03-10 15:35:51 -07:00
parent 712d46868a
commit 37ba434efb
1 changed files with 1 additions and 1 deletions

View File

@ -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)