diff options
| author | Aaron Davidson <aaron@databricks.com> | 2014-11-07 09:42:21 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2014-11-07 09:42:21 -0800 |
| commit | d4fa04e50d299e9cad349b3781772956453a696b (patch) | |
| tree | d561c5ac49c49b56aba2fa7964587a9e72c253a9 /python | |
| parent | 3abdb1b24aa48f21e7eed1232c01d3933873688c (diff) | |
| download | spark-d4fa04e50d299e9cad349b3781772956453a696b.tar.gz spark-d4fa04e50d299e9cad349b3781772956453a696b.tar.bz2 spark-d4fa04e50d299e9cad349b3781772956453a696b.zip | |
[SPARK-4187] [Core] Switch to binary protocol for external shuffle service messages
This PR elimiantes the network package's usage of the Java serializer and replaces it with Encodable, which is a lightweight binary protocol. Each message is preceded by a type id, which will allow us to change messages (by only adding new ones), or to change the format entirely by switching to a special id (such as -1).
This protocol has the advantage over Java that we can guarantee that messages will remain compatible across compiled versions and JVMs, though it does not provide a clean way to do schema migration. In the future, it may be good to use a more heavy-weight serialization format like protobuf, thrift, or avro, but these all add several dependencies which are unnecessary at the present time.
Additionally this unifies the RPC messages of NettyBlockTransferService and ExternalShuffleClient.
Author: Aaron Davidson <aaron@databricks.com>
Closes #3146 from aarondav/free and squashes the following commits:
ed1102a [Aaron Davidson] Remove some unused imports
b8e2a49 [Aaron Davidson] Add appId to test
538f2a3 [Aaron Davidson] [SPARK-4187] [Core] Switch to binary protocol for external shuffle service messages
Diffstat (limited to 'python')
0 files changed, 0 insertions, 0 deletions