From d1aeb0bc367bf807cbd8aeb0c984cd311459cc01 Mon Sep 17 00:00:00 2001 From: jingz-db Date: Thu, 15 Feb 2024 11:30:00 -0800 Subject: [PATCH] scala style --- .../io/delta/sharing/spark/DeltaFormatSharingSourceSuite.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sharing/src/test/scala/io/delta/sharing/spark/DeltaFormatSharingSourceSuite.scala b/sharing/src/test/scala/io/delta/sharing/spark/DeltaFormatSharingSourceSuite.scala index 3e87698d4d6..5497984e3a7 100644 --- a/sharing/src/test/scala/io/delta/sharing/spark/DeltaFormatSharingSourceSuite.scala +++ b/sharing/src/test/scala/io/delta/sharing/spark/DeltaFormatSharingSourceSuite.scala @@ -33,7 +33,7 @@ import org.apache.spark.SparkEnv import org.apache.spark.sql.Row import org.apache.spark.sql.delta.sharing.DeltaSharingTestSparkUtils import org.apache.spark.sql.functions.{col, lit} -import org.apache.spark.sql.streaming.StreamingQueryExceptions +import org.apache.spark.sql.streaming.StreamingQueryException import org.apache.spark.sql.streaming.StreamTest import org.apache.spark.sql.types.{ DateType, @@ -974,6 +974,7 @@ class DeltaFormatSharingSourceSuite var e = intercept[StreamingQueryException] { processAllAvailableInStream(0) } + assert(e.getCause.asInstanceOf[DeltaIllegalStateException].getErrorClass == "DELTA_SCHEMA_CHANGED_WITH_STARTING_OPTIONS") assert(e.getMessage.contains("Detected schema change in version 3"))