Re: IcebergSourceReader metrics

Hi Péter, Yes, this is exactly what I was looking for. Thanks! Chetas On Thu, Mar 28, 2024 at 11:19 PM Péter Váry wrote: > Hi Chetas, > Are you looking for this information? > > * public IcebergSourceReaderMetrics(MetricGroup metrics, String > fullTableName) {* > *MetricGroup readerMetrics

Impact on using clean code and serializing everything

Hi, We would like to adhere to clean code and expose all dependencies in the constructor of the process functions In flink, however, all dependencies passed to process functions must be serializable. Another workaround is to instantiate these dependencies in the open method of the process functio