-
Notifications
You must be signed in to change notification settings - Fork 28.9k
[SPARK-4973][CORE] Local directory in the driver of client-mode continues remaining even if application finished when external shuffle is enabled #3811
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
… local directories of the driver of local-mode when external shuffle service is enabled
|
Test build #24834 has finished for PR 3811 at commit
|
|
Does this define a new system property just for deployment mode? This logic looks like it is applied even when external shuffle service is not enabled. Why is the driver behavior special here? |
|
If we run client-mode including local-mode, driver runs on client and executors doesn't run on client so no one shared the local directories of the driver. |
|
Test build #25233 has finished for PR 3811 at commit
|
|
Why does it matter whether it's client mode or cluster mode? I'd say it should always clean it if it's the driver (which doesn't get killed throughout the application). |
|
@andrewor14 Ah, exactly. The driver is not killed until the end of the application. I'll fix my previous changes. |
|
LGTM merging into master when tests pass |
|
Test build #25253 has finished for PR 3811 at commit
|
|
retest this please |
|
Test build #25257 has finished for PR 3811 at commit
|
…nues remaining even if application finished when external shuffle is enabled When we enables external shuffle service, local directories in the driver of client-mode continue remaining even if application has finished. I think local directories for drivers should be deleted. Author: Kousuke Saruta <[email protected]> Closes #3811 from sarutak/SPARK-4973 and squashes the following commits: ad944ab [Kousuke Saruta] Fixed DiskBlockManager to cleanup local directory if it's the driver 43770da [Kousuke Saruta] Merge branch 'master' of git://git.apache.org/spark into SPARK-4973 88feecd [Kousuke Saruta] Merge branch 'master' of git://git.apache.org/spark into SPARK-4973 d99718e [Kousuke Saruta] Fixed SparkSubmit.scala and DiskBlockManager.scala in order to delete local directories of the driver of local-mode when external shuffle service is enabled (cherry picked from commit a00af6b) Signed-off-by: Andrew Or <[email protected]>
When we enables external shuffle service, local directories in the driver of client-mode continue remaining even if application has finished.
I think local directories for drivers should be deleted.