SML0127 opened a new pull request, #3529: URL: https://github.com/apache/flink-cdc/pull/3529
Added numRecordsOut metrics for each OperationType INSERT, UPDATE, DELETE. Removed table identifier from metrics name. With monitoring tools such as prometheus, we can distinguish flink job or db, table using metric attributes. Don't support numRecordsOutSnapshot. Because, the value of numRecordsOut metrics in Flink will same with numRecodsOutSnapshot. related pr: [feature/add-metric-num-records-out-by-data-change-event](https://github.com/apache/flink-cdc/pull/3456) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
