Hey there, is there any reason why in the flink docs here the examples for a counter metric extend

RichMapFunction

whereas in Python (PyFlink) it is just a normal

MapFunction

? How does the open method lifecycle work in the context of PyFlink in this case?

@Felix Angell All the functions in Python are rich and so there is no RichMapFunction. See https://github.com/apache/flink/blob/master/flink-python/pyflink/datastream/functions.py#L197 which provides

open

method in the base class.

interesting maybe we ran into a bug but only MapFunction seems to work for us (AWS KDA w. version 1.13.2) 🤔