diff --git a/cdc/owner/ddl_manager.go b/cdc/owner/ddl_manager.go index 2f569b06310..33bcae1e2ab 100644 --- a/cdc/owner/ddl_manager.go +++ b/cdc/owner/ddl_manager.go @@ -216,7 +216,7 @@ func (m *ddlManager) trySendBootstrap(ctx context.Context, currentTables []*mode log.Info("start to send bootstrap messages", zap.Stringer("changefeed", m.changfeedID), zap.Int("tables", len(currentTables))) - for _, table := range currentTables { + for idx, table := range currentTables { if table.TableInfo.IsView() { continue } @@ -228,6 +228,8 @@ func (m *ddlManager) trySendBootstrap(ctx context.Context, currentTables []*mode if err != nil { log.Error("send bootstrap message failed", zap.Stringer("changefeed", m.changfeedID), + zap.Int("tables", len(currentTables)), + zap.Int("emitted", idx+1), zap.Duration("duration", time.Since(start)), zap.Error(err)) m.reportError(err)