Skip to content

Commit 2ad5ed5

Browse files
committed
[SPARK-3736] Cancel attempts to reconnect if the master changes.
1 parent b5b34af commit 2ad5ed5

File tree

1 file changed

+1
-0
lines changed
  • core/src/main/scala/org/apache/spark/deploy/worker

1 file changed

+1
-0
lines changed

core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -159,6 +159,7 @@ private[spark] class Worker(
159159
throw new SparkException("Invalid spark URL: " + x)
160160
}
161161
connected = true
162+
scheduledReconnectMessage.foreach(_.cancel())
162163
}
163164

164165
def tryRegisterAllMasters() {

0 commit comments

Comments
 (0)