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? stream.map(new MapFunction[I,O]).addSink(discard) Hao Sun Team Lead 1019 Market St. 7F San Francisco, CA 94103
