Hi Santhosh, There's currently an ongoing discussion on this topic in the Dev mailing list, see https://lists.apache.org/thread/dqw5jw4hmyct47j7m13vdfqcdnbgq0lw
Best regards, Martijn Visser https://twitter.com/MartijnVisser82 https://github.com/MartijnVisser On Fri, 6 May 2022 at 04:31, santhosh venkat <santhoshvenkat1...@gmail.com> wrote: > Hi, > > We are trying to develop Flink SQL connectors in my company for proprietary > data-stores. One problem we observed is that the Flink-SQL > LookupTablesource/LookupFunction does not seem to have capabilities to emit > any metrics(i.e there is no metric group wired into either through > LookupSourceContext or DynamicSourceContext). It would be great to expose > latency and throughput metrics from these table sinks for monitoring. > > I looked at the existing lookuptablesource implementations in open source > Flink. I noticed that none of them were emitting any metrics. Does such a > capability exist? Please let me know if I'm missing something. > > Thanks. >
