Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
liujiayi771 committed Dec 6, 2023
1 parent faaf047 commit 5ecd2f5
Showing 1 changed file with 7 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -207,18 +207,14 @@ class GlutenClickHouseTPCHMetricsSuite extends GlutenClickHouseTPCHAbstractSuite
case g: GlutenPlan if !g.isInstanceOf[InputIteratorTransformer] => g
}

// scalastyle:off println
println("=========================")
allGlutenPlans.foreach(p => println(p.toString))
println("=========================")
val scanPlan = allGlutenPlans(10)
val scanPlan = allGlutenPlans(9)
assert(scanPlan.metrics("scanTime").value == 2)
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(9)
val filterPlan = allGlutenPlans(8)
assert(filterPlan.metrics("totalTime").value == 1)
assert(filterPlan.metrics("inputWaitTime").value == 13)
assert(filterPlan.metrics("outputWaitTime").value == 1)
Expand All @@ -227,7 +223,7 @@ class GlutenClickHouseTPCHMetricsSuite extends GlutenClickHouseTPCHAbstractSuite
assert(filterPlan.metrics("inputRows").value == 80000)
assert(filterPlan.metrics("inputBytes").value == 2160000)

val joinPlan = allGlutenPlans(3)
val joinPlan = allGlutenPlans(2)
assert(joinPlan.metrics("totalTime").value == 1)
assert(joinPlan.metrics("inputWaitTime").value == 6)
assert(joinPlan.metrics("outputWaitTime").value == 0)
Expand All @@ -247,7 +243,10 @@ class GlutenClickHouseTPCHMetricsSuite extends GlutenClickHouseTPCHAbstractSuite
val allGlutenPlans = wholeStageTransformer2.collect {
case g: GlutenPlan if !g.isInstanceOf[InputIteratorTransformer] => g
}

// scalastyle:off println
println("=========================")
allGlutenPlans.foreach(p => println(p.toString))
println("=========================")
assert(allGlutenPlans.size == 58)

val shjPlan = allGlutenPlans(8)
Expand Down

0 comments on commit 5ecd2f5

Please sign in to comment.