File tree Expand file tree Collapse file tree 1 file changed +11
-0
lines changed
src/frontend/src/stream_fragmenter Expand file tree Collapse file tree 1 file changed +11
-0
lines changed Original file line number Diff line number Diff line change @@ -70,6 +70,7 @@ pub struct BuildFragmentGraphState {
70
70
71
71
has_source_backfill : bool ,
72
72
has_snapshot_backfill : bool ,
73
+ has_cross_db_snapshot_backfill : bool ,
73
74
}
74
75
75
76
impl BuildFragmentGraphState {
@@ -172,6 +173,15 @@ pub fn build_graph_with_strategy(
172
173
. to_owned ( ) ,
173
174
) ) ) ;
174
175
}
176
+ if state. has_cross_db_snapshot_backfill
177
+ && let Some ( ref backfill_order) = backfill_order
178
+ && !backfill_order. order . is_empty ( )
179
+ {
180
+ return Err ( RwError :: from ( NotSupported (
181
+ "Backfill order control with cross-db snapshot backfill is not supported" . to_owned ( ) ,
182
+ "Please remove backfill order specification from your query" . to_owned ( ) ,
183
+ ) ) ) ;
184
+ }
175
185
176
186
let mut fragment_graph = state. fragment_graph . to_protobuf ( ) ;
177
187
@@ -372,6 +382,7 @@ fn build_fragment(
372
382
StreamScanType :: CrossDbSnapshotBackfill => {
373
383
current_fragment. fragment_type_mask |=
374
384
FragmentTypeFlag :: CrossDbSnapshotBackfillStreamScan as u32 ;
385
+ state. has_cross_db_snapshot_backfill = true ;
375
386
}
376
387
StreamScanType :: Unspecified
377
388
| StreamScanType :: Chain
You can’t perform that action at this time.
0 commit comments