Skip to content

Commit

Permalink
scala style
Browse files Browse the repository at this point in the history
  • Loading branch information
jingz-db committed Feb 15, 2024
1 parent 8fcb9fb commit d1aeb0b
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down Expand Up @@ -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"))
Expand Down

0 comments on commit d1aeb0b

Please sign in to comment.