Skip to content

Commit eb19115

Browse files
committed
chore(processor): resolve conflicts during cherry-pick of pingcap#11624
1 parent f9080bd commit eb19115

File tree

1 file changed

+0
-8
lines changed

1 file changed

+0
-8
lines changed

cdc/processor/processor.go

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -466,16 +466,8 @@ func (p *processor) GetTableStatus(tableID model.TableID, collectStat bool) tabl
466466
}
467467
}
468468

469-
<<<<<<< HEAD
470469
func (p *processor) getStatsFromSourceManagerAndSinkManager(tableID model.TableID, sinkStats sinkmanager.TableStats) tablepb.Stats {
471470
pullerStats := p.sourceManager.GetTablePullerStats(tableID)
472-
now := p.upstream.PDClock.CurrentTime()
473-
=======
474-
func (p *processor) getStatsFromSourceManagerAndSinkManager(
475-
span tablepb.Span, sinkStats sinkmanager.TableStats,
476-
) tablepb.Stats {
477-
pullerStats := p.sourceManager.r.GetTablePullerStats(span)
478-
>>>>>>> 1b026f6b75 (cordinator(ticdc): Fix Puller Resolved TS Lag Calculation and Deprecate current_ts Field in Stats (#11624))
479471

480472
stats := tablepb.Stats{
481473
RegionCount: pullerStats.RegionCount,

0 commit comments

Comments
 (0)