最简单的方式就是自定义Source,里面定时检测配置文件是否有更新,如果有更新的话就发送配置文件的内容,下游算子把这个source发送的内容当做广播变量


| |
熊云昆
|
|
邮箱:[email protected]
|

签名由 网易邮箱大师 定制

在2020年12月08日 17:36,Lei Wang 写道:
flink 程序读配置文件,配置文件的内容作为广播变量广播出去。

如果配置文件更新了,怎样能把广播变量的内容也更新呢?

谢谢,
王磊

回复