hi! I'm trying to pass Configuration parameters to a RichMapFunction in
flink streaming and I can't find the way to do it

I need to pass two strings to the MapFunction and I was getting a
serialization error, so I tried RichMapFunction and open() but I can't find
a way to set the the parameters I get at open(Configuration params)

withParameters seems to be only defined for batch from what I've seen.

how do I make a serializable MapFunction that receives two strings as
configuration from outside its definition?

Reply via email to