-
- Downloads
[SPARK-11996][CORE] Make the executor thread dump work again
In the previous implementation, the driver needs to know the executor listening address to send the thread dump request. However, in Netty RPC, the executor doesn't listen to any port, so the executor thread dump feature is broken. This patch makes the driver use the endpointRef stored in BlockManagerMasterEndpoint to send the thread dump request to fix it. Author: Shixiong Zhu <shixiong@databricks.com> Closes #9976 from zsxwing/executor-thread-dump.
Showing
- core/src/main/scala/org/apache/spark/SparkContext.scala 3 additions, 7 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/executor/Executor.scala 0 additions, 5 deletionscore/src/main/scala/org/apache/spark/executor/Executor.scala
- core/src/main/scala/org/apache/spark/executor/ExecutorEndpoint.scala 0 additions, 43 deletions...in/scala/org/apache/spark/executor/ExecutorEndpoint.scala
- core/src/main/scala/org/apache/spark/storage/BlockManagerMaster.scala 2 additions, 2 deletions...n/scala/org/apache/spark/storage/BlockManagerMaster.scala
- core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala 5 additions, 7 deletions...org/apache/spark/storage/BlockManagerMasterEndpoint.scala
- core/src/main/scala/org/apache/spark/storage/BlockManagerMessages.scala 6 additions, 1 deletion...scala/org/apache/spark/storage/BlockManagerMessages.scala
- core/src/main/scala/org/apache/spark/storage/BlockManagerSlaveEndpoint.scala 5 additions, 2 deletions.../org/apache/spark/storage/BlockManagerSlaveEndpoint.scala
- project/MimaExcludes.scala 8 additions, 0 deletionsproject/MimaExcludes.scala
Loading
Please register or sign in to comment