that was certainly a very nasty bug. Thanks! 2012/10/17 Edward J. Yoon <edwardy...@apache.org>
> 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 >
