Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
xxchan committed Mar 25, 2024
1 parent 9f8f533 commit 78a783f
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/meta/src/model/stream.rs
Original file line number Diff line number Diff line change
Expand Up @@ -374,7 +374,7 @@ impl TableFragments {
& (FragmentTypeFlag::Values as u32 | FragmentTypeFlag::StreamScan as u32))
!= 0;
// Note: CDC table fragment is both StreamScan and CdcFilter fragment. We don't want to track CDC progress.
let is_cdc = (fragment_type_mask & FragmentTypeFlag::CdcFilter as u32) == 0;
let is_cdc = (fragment_type_mask & FragmentTypeFlag::CdcFilter as u32) != 0;
is_value_or_scan && !is_cdc
})
}
Expand Down

0 comments on commit 78a783f

Please sign in to comment.