Login  Register

回复:flink如何传递全局变量

Posted by Yichao Yang on Jun 09, 2020; 12:17pm
URL: http://apache-flink.370.s1.nabble.com/flink-tp3763p3764.html

Hi


使用rich function,在open方法中加载,如果配置可能会发生变化,可以使用broadcast。


Best,
Yichao Yang




------------------ 原始邮件 ------------------
发件人:&nbsp;"[hidden email]"<[hidden email]&gt;;
发送时间:&nbsp;2020年6月9日(星期二) 晚上8:14
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;flink如何传递全局变量



hi,
&nbsp;&nbsp;&nbsp; 请问flink如何传递全局变量,静态类好像服务器端运行不行。
&nbsp;&nbsp;&nbsp; 场景是:一开始flink程序起来时,读取配置文件中的配置项,此类配置项可能会在sink,source等等其他地方用到,算是整个程序的全局配置



[hidden email]