diff options
| author | Shixiong Zhu <shixiong@databricks.com> | 2016-04-21 11:51:04 -0700 |
|---|---|---|
| committer | Shixiong Zhu <shixiong@databricks.com> | 2016-04-21 11:51:04 -0700 |
| commit | e4904d870a0e705a3a7d370320e6f8a5f23d5944 (patch) | |
| tree | f93943d5bc88283a3c23ca075d79f9520be24552 /sql | |
| parent | 3a21e8d5ed640e3f82946893e24c099aa723c169 (diff) | |
| download | spark-e4904d870a0e705a3a7d370320e6f8a5f23d5944.tar.gz spark-e4904d870a0e705a3a7d370320e6f8a5f23d5944.tar.bz2 spark-e4904d870a0e705a3a7d370320e6f8a5f23d5944.zip | |
[SPARK-14699][CORE] Stop endpoints before closing the connections and don't stop client in Outbox
## What changes were proposed in this pull request?
In general, `onDisconnected` is for dealing with unexpected network disconnections. When RpcEnv.shutdown is called, the disconnections are expected so RpcEnv should not fire these events.
This PR moves `dispatcher.stop()` above closing the connections so that when stopping RpcEnv, the endpoints won't receive `onDisconnected` events.
In addition, Outbox should not close the client since it will be reused by others. This PR fixes it as well.
## How was this patch tested?
test("SPARK-14699: RpcEnv.shutdown should not fire onDisconnected events")
Author: Shixiong Zhu <shixiong@databricks.com>
Closes #12481 from zsxwing/SPARK-14699.
Diffstat (limited to 'sql')
0 files changed, 0 insertions, 0 deletions