hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1390936 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HadoopMessageManagerImpl.java
Date Thu, 27 Sep 2012 10:52:02 GMT
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) {



Mime
View raw message