Skip to content

Commit 346f8ab

Browse files
committed
update
1 parent ca50036 commit 346f8ab

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

maintainer/replica/default_span_split_checker.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,7 @@ func (s *defaultSpanSplitChecker) UpdateStatus(replica *SpanReplication) {
128128

129129
// check traffic first
130130
if status.GetStatus().EventSizePerSecond != 0 {
131-
if status.GetStatus().EventSizePerSecond < float32(s.writeThreshold) {
131+
if s.writeThreshold == 0 || status.GetStatus().EventSizePerSecond < float32(s.writeThreshold) {
132132
status.trafficScore = 0
133133
} else {
134134
status.trafficScore++
@@ -147,7 +147,7 @@ func (s *defaultSpanSplitChecker) UpdateStatus(replica *SpanReplication) {
147147
status.regionCheckTime = time.Now()
148148
}
149149

150-
log.Info("default span split checker: update status", zap.String("changefeed", s.changefeedID.Name()), zap.String("replica", replica.ID.String()), zap.Int("trafficScore", status.trafficScore), zap.Int("regionCount", status.regionCount))
150+
log.Debug("default span split checker: update status", zap.String("changefeed", s.changefeedID.Name()), zap.String("replica", replica.ID.String()), zap.Int("trafficScore", status.trafficScore), zap.Int("regionCount", status.regionCount))
151151

152152
if status.trafficScore >= trafficScoreThreshold || (s.regionThreshold > 0 && status.regionCount >= s.regionThreshold) {
153153
if _, ok := s.splitReadyTasks[status.ID]; !ok {

0 commit comments

Comments
 (0)