Thanks for replying, Pavan. I figured out that my message Writable (an
ArrayListWritable) needed to call clear() in readFields() before
calling super():
@Override
public void readFields(DataInput in) throws IOException {
clear();
super.readFields(in);
}
This was an '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 no
