-
Notifications
You must be signed in to change notification settings - Fork 29k
[SPARK-43398][CORE] Executor timeout should be max of idle shuffle and rdd timeout #41082
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.
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
Conversation
|
@dongjoon-hyun help take a look? |
dongjoon-hyun
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The removed code seems to be originated from Apache Spark 3.0.0. Could you give a correct Affected Versions to SPARK-43398 if you think this is a bug, @warrenzhu25 ?
Done. |
af27199 to
11319ec
Compare
core/src/main/scala/org/apache/spark/scheduler/dynalloc/ExecutorMonitor.scala
Outdated
Show resolved
Hide resolved
core/src/main/scala/org/apache/spark/scheduler/dynalloc/ExecutorMonitor.scala
Outdated
Show resolved
Hide resolved
core/src/main/scala/org/apache/spark/scheduler/dynalloc/ExecutorMonitor.scala
Outdated
Show resolved
Hide resolved
7fb6690 to
4ed4c2d
Compare
mridulm
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The changes look good to me.
Thanks for helping refine this @dongjoon-hyun !
dongjoon-hyun
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
+1, LGTM.
|
Merged to master/3.4/3.3. |
…d rdd timeout ### What changes were proposed in this pull request? Executor timeout should be max of idle, shuffle and rdd timeout ### Why are the changes needed? Wrong timeout value when combining idle, shuffle and rdd timeout ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Added test in `ExecutorMonitorSuite` Closes #41082 from warrenzhu25/max-timeout. Authored-by: Warren Zhu <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]> (cherry picked from commit 7107742) Signed-off-by: Dongjoon Hyun <[email protected]>
…d rdd timeout ### What changes were proposed in this pull request? Executor timeout should be max of idle, shuffle and rdd timeout ### Why are the changes needed? Wrong timeout value when combining idle, shuffle and rdd timeout ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Added test in `ExecutorMonitorSuite` Closes #41082 from warrenzhu25/max-timeout. Authored-by: Warren Zhu <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]> (cherry picked from commit 7107742) Signed-off-by: Dongjoon Hyun <[email protected]>
|
Also, cc @Ngone51 |
…d rdd timeout ### What changes were proposed in this pull request? Executor timeout should be max of idle, shuffle and rdd timeout ### Why are the changes needed? Wrong timeout value when combining idle, shuffle and rdd timeout ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Added test in `ExecutorMonitorSuite` Closes apache#41082 from warrenzhu25/max-timeout. Authored-by: Warren Zhu <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]>
…d rdd timeout ### What changes were proposed in this pull request? Executor timeout should be max of idle, shuffle and rdd timeout ### Why are the changes needed? Wrong timeout value when combining idle, shuffle and rdd timeout ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Added test in `ExecutorMonitorSuite` Closes apache#41082 from warrenzhu25/max-timeout. Authored-by: Warren Zhu <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]> (cherry picked from commit 7107742) Signed-off-by: Dongjoon Hyun <[email protected]>
…d rdd timeout ### What changes were proposed in this pull request? Executor timeout should be max of idle, shuffle and rdd timeout ### Why are the changes needed? Wrong timeout value when combining idle, shuffle and rdd timeout ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Added test in `ExecutorMonitorSuite` Closes apache#41082 from warrenzhu25/max-timeout. Authored-by: Warren Zhu <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]> (cherry picked from commit 7107742) Signed-off-by: Dongjoon Hyun <[email protected]>
…d rdd timeout ### What changes were proposed in this pull request? Executor timeout should be max of idle, shuffle and rdd timeout ### Why are the changes needed? Wrong timeout value when combining idle, shuffle and rdd timeout ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? Added test in `ExecutorMonitorSuite` Closes apache#41082 from warrenzhu25/max-timeout. Authored-by: Warren Zhu <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]> (cherry picked from commit 7107742) Signed-off-by: Dongjoon Hyun <[email protected]>

What changes were proposed in this pull request?
Executor timeout should be max of idle, shuffle and rdd timeout
Why are the changes needed?
Wrong timeout value when combining idle, shuffle and rdd timeout
Does this PR introduce any user-facing change?
No
How was this patch tested?
Added test in
ExecutorMonitorSuite