Skip to content

Commit 1c21e59

Browse files
committed
Update YarnSchedulerBackend.scala
1 parent b0482ed commit 1c21e59

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

resource-managers/yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnSchedulerBackend.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ private[spark] abstract class YarnSchedulerBackend(
170170
yarnSchedulerEndpointRef.ask[Boolean](KillExecutors(executorIds))
171171
}
172172

173-
override protected def onExecutorRegistered(executorId: String, resourceProfileId: Int): Unit = {
173+
override def onExecutorRegistered(executorId: String, resourceProfileId: Int): Unit = {
174174
amEndpoint.foreach(_.send(ExecutorRegisteredOnDriver(executorId, resourceProfileId)))
175175
}
176176

0 commit comments

Comments
 (0)