-
Notifications
You must be signed in to change notification settings - Fork 28.6k
[SPARK-17696][core] Partial backport of SPARK-12330 to branch-1.6. #15270
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
From the original commit message: This PR also fixes a regression caused by [SPARK-10987] whereby submitting a shutdown causes a race between the local shutdown procedure and the notification of the scheduler driver disconnection. If the scheduler driver disconnection wins the race, the coarse executor incorrectly exits with status 1 (instead of the proper status 0) Author: Charles Allen <charles@allen-net.com> (cherry picked from commit 2eaeafe)
Test build #66002 has finished for PR 15270 at commit
|
Let's see if someone in interested in looking at this... @zsxwing ? |
@@ -45,6 +46,7 @@ private[spark] class CoarseGrainedExecutorBackend( | |||
env: SparkEnv) | |||
extends ThreadSafeRpcEndpoint with ExecutorBackend with Logging { | |||
|
|||
private[this] val stopping = new AtomicBoolean(false) |
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.
Nit: This can be just a simple var
since this is a ThreadSafeRpcEndpoint
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.
This is the same as in master, I'd rather keep the code the same. If you really care, it's better to change it on master.
LGTM except a nit. |
Okey. I'm going to merge it. We can change it in another PR on master. |
From the original commit message: This PR also fixes a regression caused by [SPARK-10987] whereby submitting a shutdown causes a race between the local shutdown procedure and the notification of the scheduler driver disconnection. If the scheduler driver disconnection wins the race, the coarse executor incorrectly exits with status 1 (instead of the proper status 0) Author: Charles Allen <charlesallen-net.com> (cherry picked from commit 2eaeafe) Author: Charles Allen <charles@allen-net.com> Closes #15270 from vanzin/SPARK-17696.
@vanzin Merged. Could you close this PR, please? |
From the original commit message:
This PR also fixes a regression caused by [SPARK-10987] whereby submitting a shutdown causes a race between the local shutdown procedure and the notification of the scheduler driver disconnection. If the scheduler driver disconnection wins the race, the coarse executor incorrectly exits with status 1 (instead of the proper status 0)
Author: Charles Allen charles@allen-net.com
(cherry picked from commit 2eaeafe)