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.