Author: edwardyoon
Date: Wed Oct 17 08:28:58 2012
New Revision: 1399149
URL: http://svn.apache.org/viewvc?rev=1399149&view=rev
Log:
Fix no data send bug
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=1399149&r1=1399148&r2=1399149&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
Wed Oct 17 08:28:58 2012
@@ -112,6 +112,8 @@ public final class HadoopMessageManagerI
} else {
bspPeerConnection.put(bundle);
}
+ } else {
+ bspPeerConnection.put(bundle);
}
} else {
bspPeerConnection.put(bundle);