Re: Metrics are not reported in Python UDF (used inside FlinkSQL) when exception is raised

2023-07-31 Thread liu ron
Hi, Elkhan I have one question, what metrics are not reported? Best, Ron Elkhan Dadashov 于2023年7月28日周五 05:46写道: > Hi Flinkers, > > Wanted to check if anyone else has faced this issue before: > > When Python UDF (which is used inside FlinkSQL) raises an exception, then > metrics get lost and

Metrics are not reported in Python UDF (used inside FlinkSQL) when exception is raised

2023-07-27 Thread Elkhan Dadashov
Hi Flinkers, Wanted to check if anyone else has faced this issue before: When Python UDF (which is used inside FlinkSQL) raises an exception, then metrics get lost and not reported. Facing this issue both in Flink 1.16.2 and FLink 1.17.1 (Python 3.9). If an exception is not raised, then metrics