Skip to content

Commit 80578c0

Browse files
authored
for 2.2: cdc sync timing (#22212)
cdc sync will do once immediately no matter of the frequency Approved by: @XuPeng-SH, @ck89119
1 parent cde3a8b commit 80578c0

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

pkg/cdc/reader.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -184,6 +184,11 @@ func (reader *tableReader) Run(
184184
)
185185
}()
186186

187+
if err = reader.readTable(ctx, ar); err != nil {
188+
logutil.Errorf("cdc tableReader(%v) initial sync failed, err: %v", reader.info, err)
189+
return
190+
}
191+
187192
for {
188193
select {
189194
case <-ctx.Done():

0 commit comments

Comments
 (0)