remove test failure

apache · Jan 20, 2025 · b472276 · b472276
1 parent 4ad5210
commit b472276
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala b/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala
@@ -254,7 +254,11 @@ abstract class CometTestBase
       dfSpark.queryExecution.explainString(ExtendedMode),
       dfComet.queryExecution.explainString(ExtendedMode))
     if (supportsExtendedExplainInfo(dfSpark.queryExecution)) {
-      assert(expectedInfo.forall(s => diff.contains(s)))
+      for (info <- expectedInfo) {
+        if (!diff.contains(info)) {
+          fail(s"Extended explain diff did not contain $info. Diff: $diff.")
+        }
+      }
     }
     val extendedInfo =
       new ExtendedExplainInfo().generateExtendedInfo(dfComet.queryExecution.executedPlan)