Hi Georg,
The recommended approach to configure user functions is to pass parameters
as (typesafe) arguments to the constructor.
Flink serializes users function objects using Java serialization and
distributes them to the workers. Hence, the configuration during plan
construction is preserved.
Be
Starting out with flint from a scala background I would like to use the
Typesafe configuration like: https://github.com/pureconfig/pureconfig,
however,
https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/best_practices.html
link
recommends to setup:
env.getConfig().setGlobalJobParamete
