Hello,
you cannot pass a configuration in the Steaming API. This way of
configuration is more of a relic from past times.
The common way to pass configure a function is to pass the parameters
through the constructor and store the values in a field.
Regards,
Chesnay
On 12.09.2016 18:27, Luis Mariano Guerra wrote:
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?
