mridulm commented on a change in pull request #34276:
URL: https://github.com/apache/spark/pull/34276#discussion_r742959214
##########
File path:
core/src/main/scala/org/apache/spark/deploy/history/HistoryServerDiskManager.scala
##########
@@ -210,7 +210,13 @@ private class HistoryServerDiskManager(
def committed(): Long = committedUsage.get()
private def deleteStore(path: File): Unit = {
- FileUtils.deleteDirectory(path)
+ try {
+ FileUtils.deleteDirectory(path)
+ } catch {
+ // Handle simultaneous eviction of the same app
+ case exception: IOException =>
+ if (path.exists()) throw exception;
Review comment:
The exception could be for some subdirectory/file within the subtree.
(Sorry for the delay)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
