fix

Author: ulysses-you

sql/core/src/test/resources/sql-tests/results/explain.sql.out

@@ -55,22 +55,22 @@ struct<plan:string>
 
 == Analyzed Logical Plan ==
 sum(DISTINCT val): bigint
-Aggregate [sum(distinct cast(val#x as bigint)) AS sum(DISTINCT val)#x]
+Aggregate [sum(distinct cast(val#x as bigint)) AS sum(DISTINCT val)#xL]
 +- SubqueryAlias spark_catalog.default.explain_temp1
    +- Relation[key#x,val#x] parquet
 
 == Optimized Logical Plan ==
-Aggregate [sum(distinct cast(val#x as bigint)) AS sum(DISTINCT val)#x]
+Aggregate [sum(distinct cast(val#x as bigint)) AS sum(DISTINCT val)#xL]
 +- Project [val#x]
    +- Relation[key#x,val#x] parquet
 
 == Physical Plan ==
-*(3) HashAggregate(keys=[], functions=[sum(distinct cast(val#x as bigint)#x)], output=[sum(DISTINCT val)#x])
+*(3) HashAggregate(keys=[], functions=[sum(distinct cast(val#x as bigint)#xL)], output=[sum(DISTINCT val)#xL])
 +- Exchange SinglePartition, true, [id=#x]
-   +- *(2) HashAggregate(keys=[], functions=[partial_sum(distinct cast(val#x as bigint)#x)], output=[sum#x])
-      +- *(2) HashAggregate(keys=[cast(val#x as bigint)#x], functions=[], output=[cast(val#x as bigint)#x])
-         +- Exchange hashpartitioning(cast(val#x as bigint)#x, 200), true, [id=#x]
-            +- *(1) HashAggregate(keys=[cast(val#x as bigint) AS cast(val#x as bigint)#x], functions=[], output=[cast(val#x as bigint)#x])
+   +- *(2) HashAggregate(keys=[], functions=[partial_sum(distinct cast(val#x as bigint)#xL)], output=[sum#xL])
+      +- *(2) HashAggregate(keys=[cast(val#x as bigint)#xL], functions=[], output=[cast(val#x as bigint)#xL])
+         +- Exchange hashpartitioning(cast(val#x as bigint)#xL, 200), true, [id=#x]
+            +- *(1) HashAggregate(keys=[cast(val#x as bigint) AS cast(val#x as bigint)#xL], functions=[], output=[cast(val#x as bigint)#xL])
                +- *(1) ColumnarToRow
                   +- FileScan parquet default.explain_temp1[val#x] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex[[not included in comparison]/{warehouse_dir}/explain_temp1], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<val:int>