add debug log

pingcap · May 18, 2020 · b8be781 · b8be781
1 parent bf26ac6
commit b8be781
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/cdc/entry/mounter.go b/cdc/entry/mounter.go
@@ -226,6 +226,7 @@ func (m *mounterImpl) unmarshalAndMountRowChanged(ctx context.Context, raw *mode
 	}
 	snap, err := m.schemaStorage.GetSnapshot(ctx, raw.CRTs)
 	if err != nil {
+		log.Error("get schema snapshot failed", zap.Any("base info of kv", baseInfo))
 		return nil, errors.Trace(err)
 	}
 	row, err := func() (*model.RowChangedEvent, error) {

diff --git a/cdc/processor.go b/cdc/processor.go
@@ -114,6 +114,7 @@ func (t *tableInfo) loadResolvedTS() uint64 {
 }
 
 func (t *tableInfo) storeResolvedTS(ts uint64) {
+	log.Info("store resolved ts of table", zap.Uint64("ts", ts), zap.Int64("tableID", t.id))
 	atomic.StoreUint64(&t.resolvedTS, ts)
 }
 
@@ -312,12 +313,13 @@ func (p *processor) positionWorker(ctx context.Context) error {
 			p.stateMu.Lock()
 			for _, table := range p.tables {
 				ts := table.loadResolvedTS()
-
+				log.Info("load resolved ts of table", zap.Uint64("ts", ts), zap.Int64("tableID", table.id))
 				if ts < minResolvedTs {
 					minResolvedTs = ts
 				}
 			}
 			p.stateMu.Unlock()
+			log.Info("min resolved ts", zap.Uint64("ts", minResolvedTs))
 
 			if minResolvedTs == p.position.ResolvedTs {
 				continue