sinkv2(ticdc): observe row size in MQ sink (#8287) (#8290)

close #8286
pingcap · Feb 17, 2023 · 57ebd32 · 57ebd32
1 parent 86004ca
commit 57ebd32
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/cdc/sinkv2/eventsink/mq/worker.go b/cdc/sinkv2/eventsink/mq/worker.go
@@ -210,6 +210,7 @@ func (w *worker) batch(
 			return index, nil
 		}
 		if msg.rowEvent != nil {
+			w.statistics.ObserveRows(msg.rowEvent.Event)
 			events[index] = msg
 			index++
 		}
@@ -228,6 +229,7 @@ func (w *worker) batch(
 			}
 
 			if msg.rowEvent != nil {
+				w.statistics.ObserveRows(msg.rowEvent.Event)
 				events[index] = msg
 				index++
 			}