scheduler(ticdc): Updating ReplicationSet.stats only when stats is no…

…t empty (#10225) (#10230) close #10224
pingcap · Feb 2, 2024 · d9077ca · d9077ca
1 parent b184ae0
commit d9077ca
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/cdc/scheduler/internal/v3/replication/replication_set.go b/cdc/scheduler/internal/v3/replication/replication_set.go
@@ -1025,7 +1025,10 @@ func (r *ReplicationSet) updateCheckpointAndStats(
 		r.Checkpoint.LastSyncedTs = checkpoint.LastSyncedTs
 	}
 
-	r.Stats = stats
+	// we only update stats when stats is not empty, because we only collect stats every 10s.
+	if stats.Size() > 0 {
+		r.Stats = stats
+	}
 }
 
 // SetHeap is a max-heap, it implements heap.Interface.