hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1611601 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMessageBundle.java
Date Fri, 18 Jul 2014 11:45:25 GMT
Author: edwardyoon
Date: Fri Jul 18 11:45:25 2014
New Revision: 1611601

URL: http://svn.apache.org/r1611601
Log:
Fix a bug of readFields() method.

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMessageBundle.java

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMessageBundle.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMessageBundle.java?rev=1611601&r1=1611600&r2=1611601&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMessageBundle.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPMessageBundle.java Fri Jul 18 11:45:25
2014
@@ -214,8 +214,9 @@ public class BSPMessageBundle<M extends 
 
   @Override
   public void readFields(DataInput in) throws IOException {
-    int numMessages = in.readInt();
-    if (numMessages > 0) {
+    this.bundleSize = in.readInt();
+    
+    if (this.bundleSize > 0) {
       className = in.readUTF();
       int bytesLength = in.readInt();
       byte[] temp = new byte[bytesLength];



Mime
View raw message