d3

Signed-off-by: Firestarman <firestarmanllc@gmail.com>
firestarman · Jan 2, 2024 · e77ca25 · e77ca25
1 parent 5c5ac3b
commit e77ca25
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sql-plugin/src/main/scala/org/apache/spark/sql/rapids/GpuFileSourceScanExec.scala b/sql-plugin/src/main/scala/org/apache/spark/sql/rapids/GpuFileSourceScanExec.scala
@@ -636,13 +636,13 @@ case class GpuFileSourceScanExec(
     logInfo("doCanonicalize with a reuse fix")
     GpuFileSourceScanExec(
       relation,
-      output.map(QueryPlan.normalizeExpressions(_, output)),
+      originalOutput.map(QueryPlan.normalizeExpressions(_, originalOutput)),
       requiredSchema,
       QueryPlan.normalizePredicates(
         filterUnusedDynamicPruningExpressions(partitionFilters), originalOutput),
       optionalBucketSet,
       optionalNumCoalescedBuckets,
-      QueryPlan.normalizePredicates(dataFilters, output),
+      QueryPlan.normalizePredicates(dataFilters, originalOutput),
       None,
       queryUsesInputFile,
       alluxioPathsMap = alluxioPathsMap)(rapidsConf)