Skip to content

Commit ffb61e7

Browse files
committed
Relax the state transition judgement
1 parent 8a75a30 commit ffb61e7

File tree

1 file changed

+3
-2
lines changed
  • core/src/main/scala/org/apache/spark/deploy/master

1 file changed

+3
-2
lines changed

core/src/main/scala/org/apache/spark/deploy/master/Master.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -257,8 +257,9 @@ private[deploy] class Master(
257257
exec.state = state
258258

259259
if (state == ExecutorState.RUNNING) {
260-
assert(oldState == ExecutorState.LAUNCHING,
261-
s"executor $execId state transfer from $oldState to RUNNING is illegal")
260+
if (oldState != ExecutorState.LAUNCHING) {
261+
logWarning(s"Executor $execId state transfer from $oldState to RUNNING is unexpected")
262+
}
262263
appInfo.resetRetryCount()
263264
}
264265

0 commit comments

Comments
 (0)