fix

apache · Dec 6, 2023 · 5e41c3a · 5e41c3a
1 parent 5ecd2f5
commit 5e41c3a
Showing 1 changed file with 36 additions and 1 deletion.
diff --git a/.../src/test/scala/io/glutenproject/execution/metrics/GlutenClickHouseTPCHMetricsSuite.scala b/.../src/test/scala/io/glutenproject/execution/metrics/GlutenClickHouseTPCHMetricsSuite.scala
@@ -208,13 +208,30 @@ class GlutenClickHouseTPCHMetricsSuite extends GlutenClickHouseTPCHAbstractSuite
         }
 
         val scanPlan = allGlutenPlans(9)
-        assert(scanPlan.metrics("scanTime").value == 2)
+        // scalastyle:off println
+        println("=========================")
+        println(scanPlan.metrics("scanTime").value)
+        println(scanPlan.metrics("inputWaitTime").value)
+        println(scanPlan.metrics("outputWaitTime").value)
+        println(scanPlan.metrics("outputRows").value)
+        println(scanPlan.metrics("outputBytes").value)
+        println("=========================")
+        assert(scanPlan.metrics("scanTime").value == 1)
         assert(scanPlan.metrics("inputWaitTime").value == 3)
         assert(scanPlan.metrics("outputWaitTime").value == 1)
         assert(scanPlan.metrics("outputRows").value == 80000)
         assert(scanPlan.metrics("outputBytes").value == 2160000)
 
         val filterPlan = allGlutenPlans(8)
+        println("=========================")
+        println(filterPlan.metrics("totalTime").value)
+        println(filterPlan.metrics("inputWaitTime").value)
+        println(filterPlan.metrics("outputWaitTime").value)
+        println(filterPlan.metrics("outputRows").value)
+        println(filterPlan.metrics("outputBytes").value)
+        println(filterPlan.metrics("inputRows").value)
+        println(filterPlan.metrics("inputBytes").value)
+        println("=========================")
         assert(filterPlan.metrics("totalTime").value == 1)
         assert(filterPlan.metrics("inputWaitTime").value == 13)
         assert(filterPlan.metrics("outputWaitTime").value == 1)
@@ -224,6 +241,15 @@ class GlutenClickHouseTPCHMetricsSuite extends GlutenClickHouseTPCHAbstractSuite
         assert(filterPlan.metrics("inputBytes").value == 2160000)
 
         val joinPlan = allGlutenPlans(2)
+        println("=========================")
+        println(joinPlan.metrics("totalTime").value)
+        println(joinPlan.metrics("inputWaitTime").value)
+        println(joinPlan.metrics("outputWaitTime").value)
+        println(joinPlan.metrics("outputRows").value)
+        println(joinPlan.metrics("outputBytes").value)
+        println(joinPlan.metrics("inputRows").value)
+        println(joinPlan.metrics("inputBytes").value)
+        println("=========================")
         assert(joinPlan.metrics("totalTime").value == 1)
         assert(joinPlan.metrics("inputWaitTime").value == 6)
         assert(joinPlan.metrics("outputWaitTime").value == 0)
@@ -250,6 +276,15 @@ class GlutenClickHouseTPCHMetricsSuite extends GlutenClickHouseTPCHAbstractSuite
         assert(allGlutenPlans.size == 58)
 
         val shjPlan = allGlutenPlans(8)
+        println("=========================")
+        println(shjPlan.metrics("totalTime").value)
+        println(shjPlan.metrics("inputWaitTime").value)
+        println(shjPlan.metrics("outputWaitTime").value)
+        println(shjPlan.metrics("outputRows").value)
+        println(shjPlan.metrics("outputBytes").value)
+        println(shjPlan.metrics("inputRows").value)
+        println(shjPlan.metrics("inputBytes").value)
+        println("=========================")
         assert(shjPlan.metrics("totalTime").value == 6)
         assert(shjPlan.metrics("inputWaitTime").value == 5)
         assert(shjPlan.metrics("outputWaitTime").value == 0)