A minor change from versions.toString to versions.mkString(", ") …

…to improve the error message for `DELTA_VERSIONS_NOT_CONTIGUOUS`. GitOrigin-RevId: 88969376bcb36256dff542cc5eaee60042d789fd
delta-io · Nov 14, 2023 · 5cd42d6 · 5cd42d6
1 parent 74cd1c9
commit 5cd42d6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/spark/src/main/scala/org/apache/spark/sql/delta/DeltaErrors.scala b/spark/src/main/scala/org/apache/spark/sql/delta/DeltaErrors.scala
@@ -929,7 +929,7 @@ trait DeltaErrorsBase
       spark: SparkSession, deltaVersions: Seq[Long]): Throwable = {
     new DeltaIllegalStateException(
       errorClass = "DELTA_VERSIONS_NOT_CONTIGUOUS",
-      messageParameters = Array(deltaVersions.toString())
+      messageParameters = Array(deltaVersions.mkString(", "))
     )
   }
 

diff --git a/spark/src/test/scala/org/apache/spark/sql/delta/DeltaLogSuite.scala b/spark/src/test/scala/org/apache/spark/sql/delta/DeltaLogSuite.scala
@@ -354,7 +354,7 @@ class DeltaLogSuite extends QueryTest
       val ex = intercept[IllegalStateException] {
         staleLog.update()
       }
-      assert(ex.getMessage.contains("Versions (Vector(0, 2)) are not contiguous."))
+      assert(ex.getMessage.contains("Versions (0, 2) are not contiguous."))
     }
   }