I found a bug of BSPMessageBundle.readFields() method. I'll commit
this directly.

Thanks.

Index: src/main/java/org/apache/hama/bsp/BSPMessageBundle.java
===================================================================
--- src/main/java/org/apache/hama/bsp/BSPMessageBundle.java
(revision 1610636)
+++ src/main/java/org/apache/hama/bsp/BSPMessageBundle.java    (working copy)
@@ -214,8 +214,9 @@

   @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];


-- 
Best Regards, Edward J. Yoon
CEO at DataSayer Co., Ltd.

Reply via email to