We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3a6abf1 commit 7ed1caeCopy full SHA for 7ed1cae
kernel/src/scan/log_replay.rs
@@ -488,8 +488,13 @@ impl ParallelizableLogReplayProcessor for ScanLogReplayProcessor {
488
fn process_actions_batch(&self, actions_batch: ActionsBatch) -> DeltaResult<Self::Output> {
489
let ActionsBatch {
490
actions,
491
- is_log_batch: _,
+ is_log_batch,
492
} = actions_batch;
493
+ require!(
494
+ !is_log_batch,
495
+ Error::generic("Parallel checkpoint processor may only be applied to checkpoint files")
496
+ );
497
+
498
// Build an initial selection vector for the batch which has had the data skipping filter
499
// applied. The selection vector is further updated by the deduplication visitor to remove
500
// rows that are not valid adds.
0 commit comments