Minor exception message changes

watfordkcf · Aug 11, 2023 · 22df14f · 22df14f
1 parent c78daef
commit 22df14f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/storage-s3-dynamodb/src/main/java/io/delta/storage/BaseExternalLogStore.java b/storage-s3-dynamodb/src/main/java/io/delta/storage/BaseExternalLogStore.java
@@ -206,7 +206,7 @@ public void write(
                     } else {
                         if (!fs.exists(prevPath)) {
                             throw new java.nio.file.FileSystemException(
-                                String.format("previous commit %s doesn't exist", prevPath)
+                                String.format("previous commit %s doesn't exist on the file system but does in the external log store", prevPath)
                             );
                         }
                     }
@@ -220,7 +220,7 @@ public void write(
                         if (entry.get().complete && !fs.exists(path)) {
                             throw new java.nio.file.FileSystemException(
                                 String.format(
-                                    "Old entries for table %s still exist in the external store",
+                                    "Old entries for table %s still exist in the external log store",
                                     tablePath
                                 )
                             );

diff --git a/storage-s3-dynamodb/src/test/scala/io/delta/storage/ExternalLogStoreSuite.scala b/storage-s3-dynamodb/src/test/scala/io/delta/storage/ExternalLogStoreSuite.scala
@@ -154,7 +154,7 @@ class ExternalLogStoreSuite extends org.apache.spark.sql.delta.PublicLogStoreSui
       val e = intercept[java.nio.file.FileSystemException] {
         store.write(delta1, Iterator("one"), overwrite = false, sessionHadoopConf)
       }
-      assert(e.getMessage == s"previous commit $delta0 doesn't exist")
+      assert(e.getMessage == s"previous commit $delta0 doesn't exist on the file system but does in the external log store")
     }
   }
 
@@ -236,7 +236,7 @@ class ExternalLogStoreSuite extends org.apache.spark.sql.delta.PublicLogStoreSui
       }.getMessage
 
       val tablePath = path.getParent.getParent
-      assert(e == s"Old entries for table $tablePath still exist in the external store")
+      assert(e == s"Old entries for table $tablePath still exist in the external log store")
     }
   }