Update log

sumeet-db · Mar 28, 2024 · 56f3401 · 56f3401
1 parent 1f30a42
commit 56f3401
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/spark/src/main/scala/org/apache/spark/sql/delta/DeltaLog.scala b/spark/src/main/scala/org/apache/spark/sql/delta/DeltaLog.scala
@@ -447,7 +447,9 @@ class DeltaLog private(
         // we will verify below because we're paranoid about buggy FileSystem implementations.
         (fs.mkdirs(path), None)
       } catch {
-        // Only needed because buggy Hadoop FileSystem.mkdir wrongly throws on existing dir.
+        // A FileAlreadyExistsException is expected if a non-directory object exists but an explicit
+        // check is needed because buggy Hadoop FileSystem.mkdir wrongly throws the exception even
+        // on existing directories.
         case io: IOException =>
           val dirExists =
             try {