Hi zhen, Global configs can not be passed like this. You can set the global configs through ExecutionConfig, more details here[1].
[1] https://ci.apache.org/projects/flink/flink-docs-master/dev/best_practices.html#register-the-parameters-globally On Wed, Jul 4, 2018 at 8:27 PM, zhen li <[email protected]> wrote: > Hi: > I want to set some configs in the source functions use > getRuntimeContext().getExecutionConfig().setGlobalJobParameters( > parameterTool) > And used the configs in the downstream operators such as filter > function through the getGlobalJobParameters, But it returns null pointer > exception.Is the global config only can set in the start of streams? > >
