[
https://issues.apache.org/jira/browse/GIRAPH-1142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ravikant Dindokar updated GIRAPH-1142:
--------------------------------------
Labels: partition_exchange (was: )
> 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
> Labels: partition_exchange
>
> 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)
