Ravikant Dindokar created GIRAPH-1142:
-----------------------------------------
Summary: Adding messages to LongDoubleMessageStore fails during
partition exchange
Key: GIRAPH-1142
URL: https://issues.apache.org/jira/browse/GIRAPH-1142
Project: Giraph
Issue Type: Bug
Affects Versions: 1.2.0
Reporter: Ravikant Dindokar
Priority: Minor
In the case of partition exchange, messages for the exchanged partition are
transferred using SendPartitionCurrentMessagesRequest.
The doRequest() method calls addPartitionMessages method for the messageStore.
public void doRequest(ServerData<I, V, E> serverData) {
serverData.<M>getCurrentMessageStore().addPartitionMessages(partitionId,
vertexIdMessageMap);
}
The exchanged partition has not been added yet to the messageStore of the
destination worker. This causes NullPointerException in implementation of
addPartitionMessages() in existing messageStore.
e.g
In org.apache.giraph.comm.messages.primitives.LongDoubleMessageStore.java the
addPartitionMessages() has line 105
Long2DoubleOpenHashMap partitionMap = map.get(partitionId);
But this fails as the partition is not yet added to the map in messageStore.
This issue seems to be there with other primitive messageStore like
IntFloatMessageStore.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
