spark-instrumented-optimizer/common
sychen 064604aaa7 [SPARK-27073][CORE] Fix a race condition when handling of IdleStateEvent
## What changes were proposed in this pull request?

When TransportChannelHandler processes IdleStateEvent, it first calculates whether the last request time has timed out.
At this time, TransportClient.sendRpc initiates a request.
TransportChannelHandler gets responseHandler.numOutstandingRequests() > 0, causing the normal connection to be closed.

## How was this patch tested?

Closes #23989 from cxzl25/fix_IdleStateEvent_timeout.

Authored-by: sychen <sychen@ctrip.com>
Signed-off-by: Marcelo Vanzin <vanzin@cloudera.com>
2019-03-11 15:16:16 -07:00
..
kvstore [SPARK-26090][CORE][SQL][ML] Resolve most miscellaneous deprecation and build warnings for Spark 3 2018-11-19 09:16:42 -06:00
network-common [SPARK-27073][CORE] Fix a race condition when handling of IdleStateEvent 2019-03-11 15:16:16 -07:00
network-shuffle [SPARK-27021][CORE] Cleanup of Netty event loop group for shuffle chunk fetch requests 2019-03-05 12:31:06 -08:00
network-yarn [SPARK-27021][CORE] Cleanup of Netty event loop group for shuffle chunk fetch requests 2019-03-05 12:31:06 -08:00
sketch [SPARK-25956] Make Scala 2.12 as default Scala version in Spark 3.0 2018-11-14 16:22:23 -08:00
tags [SPARK-26026][BUILD] Published Scaladoc jars missing from Maven Central 2018-11-19 08:06:33 -06:00
unsafe [CORE][MINOR] Fix some typos about MemoryMode 2019-01-15 14:40:00 +08:00