Skip to content

Commit af4876b

Browse files
committed
Fix test "Comet native metrics: BroadcastHashJoin".
1 parent ebe85fa commit af4876b

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ import org.apache.spark.sql.catalyst.expressions.{Expression, ExpressionInfo, He
3535
import org.apache.spark.sql.catalyst.expressions.aggregate.{AggregateMode, BloomFilterAggregate}
3636
import org.apache.spark.sql.comet._
3737
import org.apache.spark.sql.comet.execution.shuffle.{CometColumnarShuffle, CometShuffleExchangeExec}
38-
import org.apache.spark.sql.execution.{CollectLimitExec, ProjectExec, SparkPlan, SQLExecution, UnionExec}
38+
import org.apache.spark.sql.execution._
3939
import org.apache.spark.sql.execution.adaptive.{AdaptiveSparkPlanExec, BroadcastQueryStageExec}
4040
import org.apache.spark.sql.execution.datasources.parquet.ParquetFileFormat
4141
import org.apache.spark.sql.execution.exchange.{BroadcastExchangeExec, ReusedExchangeExec, ShuffleExchangeExec}
@@ -712,7 +712,7 @@ class CometExecSuite extends CometTestBase {
712712
assert(metrics.contains("build_time"))
713713
assert(metrics("build_time").value > 1L)
714714
assert(metrics.contains("build_input_batches"))
715-
assert(metrics("build_input_batches").value == 25L)
715+
assert(metrics("build_input_batches").value == 5L)
716716
assert(metrics.contains("build_mem_used"))
717717
assert(metrics("build_mem_used").value > 1L)
718718
assert(metrics.contains("build_input_rows"))

0 commit comments

Comments
 (0)