Hi Leilinee, numRecordsIn should be a metric[1] reported by the operator/task, and it doesn't require support from the connector. You should be able to access it directly.
[1]. https://nightlies.apache.org/flink/flink-docs-master/docs/ops/metrics/#io Best, Feng On Thu, Nov 7, 2024 at 2:57 PM 李 琳 <leili...@outlook.com> wrote: > Dear all, > I am using the flink-connector-hive to sync records into hive table. > However, the sink conector doesn't collect operator running metrics like > numRecordsIn. so I couldn't collect these data. > > Is there a way to support the flink-connector-hive to collect flink > metrics? Or is there some methods to achieve the goal? > > Thank you to everyone who could help me. > > Best regards, > Leilinee >
