Skip to content

Commit deaf2e2

Browse files
committed
fix ut:custom_sources_cases::statistics::sql_limit(with_node_id of CoalescePartitionsExec missed fetch)
1 parent c46f7a9 commit deaf2e2

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

.github/workflows/audit.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,4 +44,4 @@ jobs:
4444
- name: Run audit check
4545
# Ignored until https://github.com/apache/datafusion/issues/15571
4646
# ignored py03 warning until arrow 55 upgrade
47-
run: cargo audit --ignore RUSTSEC-2024-0370 --ignore RUSTSEC-2025-0020
47+
run: cargo audit --ignore RUSTSEC-2024-0370 --ignore RUSTSEC-2025-0020 --ignore RUSTSEC-2025-0047

datafusion/physical-plan/src/coalesce_partitions.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -217,6 +217,7 @@ impl ExecutionPlan for CoalescePartitionsExec {
217217
_node_id: usize,
218218
) -> Result<Option<Arc<dyn ExecutionPlan>>> {
219219
let mut new_plan = CoalescePartitionsExec::new(Arc::clone(self.input()));
220+
new_plan.fetch = self.fetch;
220221
let new_props = new_plan.cache.clone().with_node_id(_node_id);
221222
new_plan.cache = new_props;
222223
Ok(Some(Arc::new(new_plan)))

0 commit comments

Comments
 (0)