Skip to content

Commit d5b053f

Browse files
committed
stream scan includes other scans
1 parent 603ccc6 commit d5b053f

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

src/meta/src/stream/stream_graph/fragment.rs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -704,8 +704,6 @@ impl StreamFragmentGraph {
704704
let fragment_id = fragment_id.as_global_id();
705705
let fragment_mask = fragment.fragment_type_mask;
706706
let candidates = [
707-
FragmentTypeFlag::CrossDbSnapshotBackfillStreamScan,
708-
FragmentTypeFlag::SnapshotBackfillStreamScan,
709707
FragmentTypeFlag::StreamScan,
710708
FragmentTypeFlag::SourceScan,
711709
];

0 commit comments

Comments
 (0)