Dear all: I use flink for real-time data synchronization（mysql,oracle --> kafka --> mysql,oracle）. I want to count how many pieces of data are synchronized every day(maybe need to count the last n days ).
I am doing this now： flink metrics send to pushgateway, and then sum the metrics (flink_taskmanager_job_task_numRecordsOut) to count how many pieces of data are synchronized every day, but i found this metrics will reset after the flink job restart, how should I deal with this problem? or is there any better way to count? <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t3167/Snipaste_2021-05-24_10-51-22.png> Best regards -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
