HI Puneet,
What are you trying to do in getAggregatedValue()? Is there any reason you
don't just want to return the current value of the aggregator (which is
what the default implementation does)?
Best,
Matthew
On Sat, Sep 20, 2014 at 6:25 AM, Puneet Agarwal puagar...@yahoo.com wrote:
I have
Hi Folks. I am refactoring my compute() to use a set of ids as its
message type, and in my tests it is receiving a message that it
absolutely did not send. I've debugged it and am at a loss.
Interestingly, I encountered this once before and solved it by
creating a copy of a Writeable instead of
Can you give more context?What are the types of messages, patch of your compute
method, etc.You will not receive messages that are not sent, but one thing that
can happen is-- message can have multiple parameters.suppose message objects
can have 2 parametersm - a,bsay in m's write(out) you do
