diff --git a/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala b/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala index 26e4675e8..ef64d666e 100644 --- a/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala +++ b/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala @@ -252,9 +252,7 @@ abstract class CometTestBase } val extendedInfo = new ExtendedExplainInfo().generateExtendedInfo(dfComet.queryExecution.executedPlan) - if (!extendedInfo.equalsIgnoreCase(expectedInfo)) { - fail(s"$extendedInfo != $expectedInfo (case-insensitive comparison)") - } + assert(extendedInfo.equalsIgnoreCase(expectedInfo)) } private var _spark: SparkSession = _