Skip to content

Commit 10709c4

Browse files
committed
feat: support PartialMerge
1 parent f12ce3e commit 10709c4

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -484,8 +484,7 @@ class CometExecSuite extends CometTestBase {
484484
case s: CometHashAggregateExec => s
485485
}.get
486486

487-
assert(
488-
agg.modes.nonEmpty && agg.modes.headOption.get.isInstanceOf[AggregateMode])
487+
assert(agg.modes.nonEmpty && agg.modes.headOption.get.isInstanceOf[AggregateMode])
489488
val newAgg = agg.cleanBlock().asInstanceOf[CometHashAggregateExec]
490489
assert(
491490
newAgg.modes.nonEmpty &&

0 commit comments

Comments
 (0)