Skip to content

Commit 80069f7

Browse files
committed
fix rebase
1 parent 6121248 commit 80069f7

File tree

3 files changed

+6
-3
lines changed

3 files changed

+6
-3
lines changed

datafusion/core/src/physical_optimizer/projection_pushdown.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -201,7 +201,7 @@ fn try_swapping_with_memory(
201201
MemoryExec::try_new(
202202
memory.partitions(),
203203
memory.original_schema(),
204-
new_projections,
204+
Some(new_projections),
205205
)
206206
.map(|e| Arc::new(e) as _)
207207
})
@@ -248,7 +248,7 @@ fn try_swapping_with_streaming_table(
248248
StreamingTableExec::try_new(
249249
streaming_table.partition_schema().clone(),
250250
streaming_table.partitions().clone(),
251-
new_projections.as_ref(),
251+
Some(new_projections.as_ref()),
252252
lex_orderings,
253253
streaming_table.is_infinite(),
254254
)

datafusion/sqllogictest/test_files/cte.slt

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,9 @@ Projection: NUMBERS.a, NUMBERS.b, NUMBERS.c
3838
physical_plan
3939
ProjectionExec: expr=[1 as a, 2 as b, 3 as c]
4040
--PlaceholderRowExec
41+
42+
43+
4144
# enable recursive CTEs
4245
statement ok
4346
set datafusion.execution.enable_recursive_ctes = true;

0 commit comments

Comments
 (0)