Skip to content

Commit d732681

Browse files
committed
Add metrics checking to CometExecSuite "CometBroadcastExchangeExec: empty broadcast".
1 parent 5ce757c commit d732681

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -497,6 +497,10 @@ class CometExecSuite extends CometTestBase {
497497
}.get.asInstanceOf[CometBroadcastExchangeExec]
498498
val rows = nativeBroadcast.executeCollect()
499499
assert(rows.isEmpty)
500+
501+
val metrics = nativeBroadcast.metrics
502+
assert(metrics("numCoalescedBatches").value == 0L)
503+
assert(metrics("numCoalescedRows").value == 0L)
500504
}
501505
}
502506
}

0 commit comments

Comments
 (0)