我们知道 Flink 作业的配置一般都是通过在作业启动的时候通过参数传递的，或者通过读取配置文件的参数，在作业启动后初始化了之后如果再想更新作业的配置一般有两种解决方法：

(1)改变启动参数或者改变配置文件，重启作业，让作业能够读取到修改后的配置

(2)通过读取配置流（需要自定义 Source 读取配置），然后流和流连接起来

(3)读取配置信息，从mysql或者redis

今天介绍的是一种用配置中心。携程 apollo、spring cloud config、nacos 等

Flink open 方法

 

invoke 方法：

 日志打印结果：

之前在京东的时候有了解过这种分布式配置中，DUCC。感兴趣的可以看看相关文档，是如何实现的。