[jira] [Closed] (SPARK-11230) Add Outbox to cache the sending messages to resolve the message disorder issue

["Shixiong Zhu (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SPARK-11230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Shixiong Zhu closed SPARK-11230.
--------------------------------
    Resolution: Duplicate

Didn't see SPARK-11098 before creating this one

> Add Outbox to cache the sending messages to resolve the message disorder issue
> ------------------------------------------------------------------------------
>
>                 Key: SPARK-11230
>                 URL: https://issues.apache.org/jira/browse/SPARK-11230
>             Project: Spark
>          Issue Type: Sub-task
>          Components: Spark Core
>            Reporter: Shixiong Zhu
>
> The current NettyRpc has a message order issue because it uses a thread pool to send messages. E.g., running the following two lines,
> {code}
> ref.send("A")
> ref.send("B")
> {code}
> The remote endpoint may see "B" before "A" because sending "A" and "B" are in parallel.
> To resolve this issue, we need to add an outbox for each connection, and if we are connecting to the remote node, we can just cache the sending messages in the outbox and send them one by one when the connection is established.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org