Skip to content

[SPARK-40778][CORE] Make HeartbeatReceiver as an IsolatedRpcEndpoint #38231

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
warrenzhu25 wants to merge 3 commits into from
Closed

[SPARK-40778][CORE] Make HeartbeatReceiver as an IsolatedRpcEndpoint #38231

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
b6e8406
Make HeartbeatReceiver as IsolatedRpcEndpoint
warrenzhu25 Oct 13, 2022
7162ccb
Fix import
warrenzhu25 Oct 13, 2022
0390cd9
resolve comments
warrenzhu25 Oct 19, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ import scala.concurrent.Future
import org.apache.spark.executor.ExecutorMetrics
import org.apache.spark.internal.{config, Logging}
import org.apache.spark.internal.config.Network
import org.apache.spark.rpc.{RpcCallContext, RpcEnv, ThreadSafeRpcEndpoint}
import org.apache.spark.rpc.{IsolatedRpcEndpoint, RpcCallContext, RpcEnv}
import org.apache.spark.scheduler._
import org.apache.spark.scheduler.cluster.CoarseGrainedClusterMessages.RemoveExecutor
import org.apache.spark.scheduler.cluster.CoarseGrainedSchedulerBackend
Expand Down Expand Up @@ -65,7 +65,7 @@ private[spark] case class HeartbeatResponse(reregisterBlockManager: Boolean)
* Lives in the driver to receive heartbeats from executors..
*/
private[spark] class HeartbeatReceiver(sc: SparkContext, clock: Clock)
extends SparkListener with ThreadSafeRpcEndpoint with Logging {
extends SparkListener with IsolatedRpcEndpoint with Logging {

def this(sc: SparkContext) = {
this(sc, new SystemClock)
Expand Down