Skip to content

Commit

Permalink
Fix test after merge
Browse files Browse the repository at this point in the history
  • Loading branch information
EnricoMi committed May 24, 2023
1 parent 2455be4 commit 0baaebd
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/test/scala/uk/co/gresearch/spark/SparkSuite.scala
Original file line number Diff line number Diff line change
Expand Up @@ -594,7 +594,7 @@ class SparkSuite extends AnyFunSuite with SparkTestSession {
}.getMessage
if (Some(spark.sparkContext.version).exists(_.startsWith("3.1."))) {
assert(message.startsWith("cannot resolve 'unix_micros(`ts`)' due to data type mismatch: argument 1 requires timestamp type, however, '`ts`' is of bigint type.;"))
} else if (Some(spark.sparkContext.version).exists(_.startsWith("3.4."))) {
} else if (Seq("3.4", "3.5").exists(ver => Some(spark.sparkContext.version).exists(_.startsWith(s"$ver.")))) {
assert(message.startsWith("[DATATYPE_MISMATCH.UNEXPECTED_INPUT_TYPE] Cannot resolve \"unix_micros(ts)\" due to data type mismatch: Parameter 1 requires the \"TIMESTAMP\" type, however \"ts\" has the type \"BIGINT\".;"))
} else {
assert(message.startsWith("cannot resolve 'unix_micros(ts)' due to data type mismatch: argument 1 requires timestamp type, however, 'ts' is of bigint type.;"))
Expand Down

0 comments on commit 0baaebd

Please sign in to comment.