Re: How to set global config in the rich functions

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 wrote:

How to set global config in the rich functions

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