Skip to content

Commit e7404de

Browse files
committed
fix
1 parent 7ad46bd commit e7404de

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

gluten-substrait/src/main/scala/org/apache/spark/sql/execution/ShuffledColumnarBatchRDD.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,12 +60,13 @@ class ShuffledColumnarBatchRDD(
6060

6161
def this(
6262
dependency: ShuffleDependency[Int, ColumnarBatch, ColumnarBatch],
63-
metrics: Map[String, SQLMetric]) = {
63+
metrics: Map[String, SQLMetric],
64+
executionMode: StageExecutionMode = CPUStageMode) = {
6465
this(
6566
dependency,
6667
metrics,
6768
Array.tabulate(dependency.partitioner.numPartitions)(i => CoalescedPartitionSpec(i, i + 1)),
68-
CPUStageMode
69+
executionMode
6970
)
7071
}
7172

0 commit comments

Comments
 (0)