This small patch fixes a bug http://twitter.com/tjungblut/status/258461672560287744
I'll refactor and add unit test tomorrow. On Wed, Oct 17, 2012 at 5:28 PM, <edwardy...@apache.org> wrote: > 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); > > -- Best Regards, Edward J. Yoon @eddieyoon
