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: [email protected]
For additional commands, e-mail: [email protected]
