Hi Hequn, Thanks for driving this. +1 to this feature.
Just one minor comment: It seems that we will add an API get_metric_group for the Python class FunctionContext, could you update the FLIP reflecting this? Thanks, Dian > 在 2020年3月10日，下午3:38，Wei Zhong <[email protected]> 写道： > > Hi Hequn, > > Thanks for driving this. +1 for the metrics support for Python UDF, which > makes it much easier for users to monitor the execution of Python UDFs. > > Best, > Wei > > >> 在 2020年3月10日，15:32，Xingbo Huang <[email protected]> 写道： >> >> Hi Hequn, >> thanks for drafting the FLIP and kicking off the discussion. >> >> +1 for this feature. >> I think this feature will be extremely convenient for PyFlink users. >> >> Best, >> Xingbo >> >> Hequn Cheng <[email protected]> 于2020年3月9日周一 上午11:32写道： >> >>> Hi everyone, >>> >>> FLIP-58 adds the support for Python UDFs, but user-defined metrics >>> have not been supported yet. With metrics, users can report and monitor >>> the UDF status to get a deeper understanding of the execution, >>> so in this FLIP, we want to support metrics for Python UDFs. >>> >>> Previously, Jincheng and I discussed offline about the support of >>> metrics for Python UDFs. We'd like to achieve three goals for >>> supporting metrics for Python UDFs: >>> - Support user-defined metrics including Counters, Gauges, Meters, >>> Distributions in Python UDFs. >>> - Support defining user scopes. >>> - Support defining user variables. >>> >>> More details can be found in the FLIP wiki page[1] and we are looking >>> forward >>> to your feedback. >>> >>> Best, >>> Hequn >>> >>> [1] >>> >>> https://cwiki.apache.org/confluence/display/FLINK/FLIP-112%3A+Support+User-Defined+Metrics+in++Python+UDF >>> >
