Skip to content

Commit

Permalink
Update cdc/owner/ddl_manager.go
Browse files Browse the repository at this point in the history
Co-authored-by: Ling Jin <[email protected]>
  • Loading branch information
asddongmen and 3AceShowHand authored Nov 21, 2023
1 parent 00eb89b commit 6a0a249
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion cdc/owner/ddl_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -198,7 +198,7 @@ func (m *ddlManager) tick(
checkpointTs model.Ts,
tableCheckpoint map[model.TableName]model.Ts,
) ([]model.TableID, *schedulepb.BarrierWithMinTs, error) {
// needBootstrap is true when the the downstream is kafka
// needBootstrap is true when the downstream is kafka
// and the protocol is simple protocol.
if m.needBootstrap {
ok, err := m.checkAndBootstrap(ctx)
Expand Down

0 comments on commit 6a0a249

Please sign in to comment.