From 619116db2bb4c9b068560316c2b026ac6af2056c Mon Sep 17 00:00:00 2001 From: Joseph Koshakow Date: Tue, 17 Dec 2024 12:12:01 -0500 Subject: [PATCH] Experiment for migrate --- src/adapter/src/catalog/open.rs | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/adapter/src/catalog/open.rs b/src/adapter/src/catalog/open.rs index 3561f18ab51b6..fd9a014d879b3 100644 --- a/src/adapter/src/catalog/open.rs +++ b/src/adapter/src/catalog/open.rs @@ -518,6 +518,11 @@ impl Catalog { // Include any post-item-updates generated by migrations, and then consolidate // them to ensure diffs are all positive. post_item_updates.extend(migrate_result.post_item_updates); + if let Some(max_ts) = post_item_updates.iter().map(|(_, ts, _)| ts).max().cloned() { + for (_, ts, _) in &mut post_item_updates { + *ts = max_ts; + } + } differential_dataflow::consolidation::consolidate_updates(&mut post_item_updates); }