test

apache · Aug 13, 2024 · 8e3c6c0 · 8e3c6c0
1 parent a768f34
commit 8e3c6c0
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/.../src/test/scala/org/apache/gluten/execution/GlutenClickHouseColumnarShuffleAQESuite.scala b/.../src/test/scala/org/apache/gluten/execution/GlutenClickHouseColumnarShuffleAQESuite.scala
@@ -17,14 +17,16 @@
 package org.apache.gluten.execution
 
 import org.apache.spark.SparkConf
+import org.apache.spark.internal.Logging
 import org.apache.spark.sql.catalyst.optimizer._
 import org.apache.spark.sql.catalyst.plans._
 import org.apache.spark.sql.execution.CoalescedPartitionSpec
 import org.apache.spark.sql.execution.adaptive.{AdaptiveSparkPlanExec, AdaptiveSparkPlanHelper, AQEShuffleReadExec}
 
 class GlutenClickHouseColumnarShuffleAQESuite
   extends GlutenClickHouseTPCHAbstractSuite
-  with AdaptiveSparkPlanHelper {
+  with AdaptiveSparkPlanHelper
+  with Logging {
 
   override protected val tablesPath: String = basePath + "/tpch-data-ch"
   override protected val tpchQueries: String = rootPath + "queries/tpch-queries-ch"
@@ -193,7 +195,9 @@ class GlutenClickHouseColumnarShuffleAQESuite
         {
           df =>
             val nodes = df.queryExecution.executedPlan.collect {
-              case node => node.getClass.getSimpleName
+              case node =>
+                logError(s"xxx node: $node")
+                node.getClass.getSimpleName
             }
             assert(nodes == Seq())
             val joins = df.queryExecution.executedPlan.collect {