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

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

Shixiong Zhu created SPARK-11230:
------------------------------------

             Summary: 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