[jira] [Updated] (GIRAPH-1142) Adding messages to LongDoubleMessageStore fails during partition exchange

["Ravikant Dindokar (JIRA)" <ji...@apache.org>]

     [ 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)