Skip to content

Commit bdd2409

Browse files
committed
fix test
1 parent eb5dae5 commit bdd2409

4 files changed

Lines changed: 4 additions & 4 deletions

File tree

datafusion/core/src/physical_planner.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3652,7 +3652,7 @@ mod tests {
36523652
.expect("hash aggregate");
36533653
assert_eq!(
36543654
"sum(aggregate_test_100.c3)",
3655-
final_hash_agg.schema().field(3).name()
3655+
final_hash_agg.schema().field(4).name()
36563656
);
36573657
// we need access to the input to the partial aggregate so that other projects can
36583658
// implement serde

datafusion/sqllogictest/test_files/group_by.slt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5222,7 +5222,7 @@ order by deptno, job, sal, grouping(deptno), grouping(job), grouping(sal);
52225222
20 MANAGER NULL NULL 0 0 1
52235223
20 NULL 3000 NULL 0 1 0
52245224

5225-
query ITIII
5225+
query ITII
52265226
select deptno, job, sal, grouping(deptno, job, sal)
52275227
from duplicate_grouping_sets
52285228
group by grouping sets ((deptno, job), (deptno, sal), (deptno, job))

datafusion/sqllogictest/test_files/grouping_set_repartition.slt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,7 @@ logical_plan
142142
physical_plan
143143
01)SortPreservingMergeExec: [channel@0 ASC, brand@1 ASC]
144144
02)--SortExec: expr=[channel@0 ASC, brand@1 ASC], preserve_partitioning=[true]
145-
03)----ProjectionExec: expr=[channel@0 as channel, brand@1 as brand, sum(sub.total)@3 as grand_total]
145+
03)----ProjectionExec: expr=[channel@0 as channel, brand@1 as brand, sum(sub.total)@4 as grand_total]
146146
04)------AggregateExec: mode=FinalPartitioned, gby=[channel@0 as channel, brand@1 as brand, __grouping_id@2 as __grouping_id, __grouping_ordinal@3 as __grouping_ordinal], aggr=[sum(sub.total)]
147147
05)--------RepartitionExec: partitioning=Hash([channel@0, brand@1, __grouping_id@2, __grouping_ordinal@3], 4), input_partitions=4
148148
06)----------AggregateExec: mode=Partial, gby=[(NULL as channel, NULL as brand), (channel@0 as channel, NULL as brand), (channel@0 as channel, brand@1 as brand)], aggr=[sum(sub.total)]

datafusion/sqllogictest/test_files/push_down_filter_regression.slt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -179,7 +179,7 @@ explain select max(id) from agg_dyn_test where id < 10
179179
group by grouping sets ((), (id))
180180
----
181181
physical_plan
182-
01)ProjectionExec: expr=[max(agg_dyn_test.id)@2 as max(agg_dyn_test.id)]
182+
01)ProjectionExec: expr=[max(agg_dyn_test.id)@3 as max(agg_dyn_test.id)]
183183
02)--AggregateExec: mode=FinalPartitioned, gby=[id@0 as id, __grouping_id@1 as __grouping_id, __grouping_ordinal@2 as __grouping_ordinal], aggr=[max(agg_dyn_test.id)]
184184
03)----RepartitionExec: partitioning=Hash([id@0, __grouping_id@1, __grouping_ordinal@2], 2), input_partitions=2
185185
04)------AggregateExec: mode=Partial, gby=[(NULL as id), (id@0 as id)], aggr=[max(agg_dyn_test.id)]

0 commit comments

Comments
 (0)