flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mikhail Pryakhin <m.prya...@gmail.com>
Subject RichMapFunction setup method
Date Tue, 13 Jun 2017 13:46:45 GMT
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

View raw message