Re: Obtaining Flink Conf in User Code

2021-09-05 Thread Arvid Heise
I think there is no easy way to access the configuration. There is GlobalConfiguration but it's marked Internal and I think it's even discouraged inside core Flink. However, usually you have full access to the Configuraiton inside your main and you can simply pass it or the desired option to your

Obtaining Flink Conf in User Code

2021-09-03 Thread Mason Chen
Hi all, Is it possible to obtain the Flink configuration in the user code? I've tried the Configuration parameter in the open method of rich functions and StreamExecutionEnvironment.getConfig().getGlobalJobParameters()--both do not give the configs in the flink configuration. Best, Mason