diff --git a/cdc/sink/mysql.go b/cdc/sink/mysql.go
index 9f0e78a6a38..575ca0ed0cd 100644
--- a/cdc/sink/mysql.go
+++ b/cdc/sink/mysql.go
@@ -128,6 +128,7 @@ func (s *mysqlSink) FlushRowChangedEvents(ctx context.Context, resolvedTs uint64
 			checkpointTs = workerCheckpointTs
 		}
 	}
+	s.statistics.PrintStatus()
 	return checkpointTs, nil
 }