Hi all! A RichMapFunction [1] provides a very handy setup method RichFunction#open(org.apache.flink.configuration.Configuration) which consumes a Configuration instance as an argument, but this argument doesn't bear any configuration parameters because it is always passed to the method as a new instance. [2] depicts the problem.
Is there any way to pass configuration parameters to the RichFunction#open method via the Configuration parameter? Or is it a bug? P.S. I'm using flink 1.3 Thanks in advance! [1] https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/common/functions/RichMapFunction.java [2] https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java#L111 Kind Regards, Mike Pryakhin
smime.p7s
Description: S/MIME cryptographic signature
