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.