You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@hama.apache.org by Thomas Jungblut <th...@gmail.com> on 2012/10/17 10:32:23 UTC
Re: svn commit: r1399149 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/message/HadoopMessageManagerImpl.java
that was certainly a very nasty bug.
Thanks!
2012/10/17 Edward J. Yoon <ed...@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, <ed...@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
>