Nope, BSP tasks are synchronized by exchanging messages at barrier synchronization step. It means that you should call sync() method between send and getCurrentMessage().
> (BTW: I think the default setting for distributed version of message manager > is HadoopMessageManagerImpl. Is it right?) Yes. On Mon, Jan 7, 2013 at 6:01 PM, realstolz.gmail <[email protected]> wrote: > I would like to know whether the message manager used by hama (distributed > version) > supports concurrently send and receive messages? > Is it safe to concurrently call peer.send() and peer.getCurrentMessage() by > multiple threads > in distributed version? > > (BTW: I think the default setting for distributed version of message manager > is HadoopMessageManagerImpl. Is it right?) > > thanks, > -Rong > -- Best Regards, Edward J. Yoon @eddieyoon
