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 154b7ab commit 564bd38Copy full SHA for 564bd38
src/adapter/src/coord/sequencer/inner.rs
@@ -3409,6 +3409,9 @@ impl Coordinator {
3409
3410
// For `ALTER SINK`, the snapshot should only occur if the sink has not made any progress.
3411
// This prevents unnecessary decoding in the sink.
3412
+ // If the write frontier of the sink is strictly larger than its read hold, it must have at
3413
+ // least written out its snapshot, and we can skip reading it; otherwise assume we may have
3414
+ // to replay from the beginning.
3415
let alter_sink_snapshot = with_snapshot && !PartialOrder::less_than(&as_of, write_frontier);
3416
3417
// Parse the `create_sql` so we can update it to the new sink definition.
0 commit comments