Experiment for migrate

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);
             }