I am using Flink 1.7 on K8S. This might does not matter :D.
I think Flink only initialize the MapFunction once per taskManager right?
Because Flink will serialize the execution graph and distribute it to taskManagers.
Or it creates a new MapFunction for every element?
1019 Market St. 7F
San Francisco, CA 94103