sink/mysql: fix statistics print status missing in MySQL sink (#1023) #…

…1024
pingcap · Oct 23, 2020 · 3801ffa · 3801ffa
1 parent 2cb98dc
commit 3801ffa
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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
 }