Skip to content

Commit 86517bd

Browse files
committed
fix tests
1 parent adde122 commit 86517bd

3 files changed

Lines changed: 5 additions & 11 deletions

File tree

datafusion/core/tests/parquet/row_group_pruning.rs

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -165,11 +165,7 @@ impl RowGroupPruningTest {
165165
self.expected_row_group_pruned_by_bloom_filter,
166166
"mismatched row_groups_pruned_bloom_filter",
167167
);
168-
assert_eq!(
169-
output.limit_pruned_row_groups(),
170-
self.expected_limit_pruned_row_groups,
171-
"mismatched limit_pruned_row_groups",
172-
);
168+
173169
assert_eq!(
174170
output.result_rows,
175171
self.expected_rows,

datafusion/execution/src/memory_pool/pool.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,9 @@ pub struct UnboundedMemoryPool {
3434
}
3535

3636
impl MemoryPool for UnboundedMemoryPool {
37-
fn grow(&self, _reservation: &MemoryReservation, _additional: usize) {}
37+
fn grow(&self, _reservation: &MemoryReservation, additional: usize) {
38+
self.used.fetch_add(additional, Ordering::Relaxed);
39+
}
3840

3941
fn shrink(&self, _reservation: &MemoryReservation, shrink: usize) {
4042
self.used.fetch_sub(shrink, Ordering::Relaxed);
@@ -258,7 +260,7 @@ fn insufficient_capacity_err(
258260
additional: usize,
259261
available: usize,
260262
) -> DataFusionError {
261-
resources_datafusion_err!("Failed to allocate additional {} for {} with {} already allocated for this reservation - {} remain available for the total pool",
263+
resources_datafusion_err!("Failed to allocate additional {} for {} with {} already allocated for this reservation - {} remain available for the total pool",
262264
human_readable_size(additional), reservation.registration.consumer.name, human_readable_size(reservation.size), human_readable_size(available))
263265
}
264266

datafusion/physical-plan/src/coalesce_batches.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -224,10 +224,6 @@ impl ExecutionPlan for CoalesceBatchesExec {
224224
self.fetch
225225
}
226226

227-
fn supports_limit_pushdown(&self) -> bool {
228-
true
229-
}
230-
231227
fn cardinality_effect(&self) -> CardinalityEffect {
232228
CardinalityEffect::Equal
233229
}

0 commit comments

Comments
 (0)