Author: edwardyoon
Date: Thu Sep 27 10:52:02 2012
New Revision: 1390936
URL: http://svn.apache.org/viewvc?rev=1390936&view=rev
Log:
My mis
Modified:
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HadoopMessageManagerImpl.java
Modified:
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HadoopMessageManagerImpl.java
URL:
http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HadoopMessageManagerImpl.java?rev=1390936&r1=1390935&r2=1390936&view=diff
==============================================================================
---
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HadoopMessageManagerImpl.java
(original)
+++
hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HadoopMessageManagerImpl.java
Thu Sep 27 10:52:02 2012
@@ -103,8 +103,8 @@ public final class HadoopMessageManagerI
} else {
if (compressor != null) {
float bundleSize = CompressionUtil.getBundleSize(bundle);
- if (CompressionUtil.getBundleSize(bundle) > conf.getLong(
- "hama.messenger.compression.threshold", 1048576)) {
+ if (bundleSize > conf.getLong("hama.messenger.compression.threshold",
+ 1048576)) {
BSPCompressedBundle compMsgBundle =
compressor.compressBundle(bundle);
if (CompressionUtil.getCompressionRatio(
(float) compMsgBundle.getData().length, bundleSize) < 1.0) {
