Skip to content

Commit 35ac892

Browse files
committed
fix
Signed-off-by: Yuan <yuanzhou@apache.org>
1 parent 76a3428 commit 35ac892

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/offload/OffloadSingleNodeRules.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -311,7 +311,7 @@ object OffloadOthers {
311311
plan.lowerBound,
312312
plan.upperBound,
313313
plan.withReplacement,
314-
plan.seed,
314+
SparkShimLoader.getSparkShims.getSampleExecSeed(plan),
315315
child)
316316
case plan: RDDScanExec if RDDScanTransformer.isSupportRDDScanExec(plan) =>
317317
RDDScanTransformer.getRDDScanTransform(plan)

shims/spark33/src/main/scala/org/apache/gluten/sql/shims/spark33/Spark33Shims.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ import org.apache.spark.sql.catalyst.rules.Rule
3434
import org.apache.spark.sql.catalyst.util.RebaseDateTime.RebaseSpec
3535
import org.apache.spark.sql.catalyst.util.TimestampFormatter
3636
import org.apache.spark.sql.connector.catalog.Table
37-
import org.apache.spark.sql.execution.{FileSourceScanExec, PartitionedFileUtil, QueryExecution, SparkPlan, SparkPlanner}
37+
import org.apache.spark.sql.execution._
3838
import org.apache.spark.sql.execution.adaptive.AdaptiveSparkPlanExec
3939
import org.apache.spark.sql.execution.datasources._
4040
import org.apache.spark.sql.execution.datasources.FileFormatWriter.Empty2Null

0 commit comments

Comments
 (0)