最简单的方式就是自定义Source,里面定时检测配置文件是否有更新,如果有更新的话就发送配置文件的内容,下游算子把这个source发送的内容当做广播变量
| | 熊云昆 | | 邮箱:[email protected] | 签名由 网易邮箱大师 定制 在2020年12月08日 17:36,Lei Wang 写道: flink 程序读配置文件,配置文件的内容作为广播变量广播出去。 如果配置文件更新了,怎样能把广播变量的内容也更新呢? 谢谢, 王磊
最简单的方式就是自定义Source,里面定时检测配置文件是否有更新,如果有更新的话就发送配置文件的内容,下游算子把这个source发送的内容当做广播变量
| | 熊云昆 | | 邮箱:[email protected] | 签名由 网易邮箱大师 定制 在2020年12月08日 17:36,Lei Wang 写道: flink 程序读配置文件,配置文件的内容作为广播变量广播出去。 如果配置文件更新了,怎样能把广播变量的内容也更新呢? 谢谢, 王磊