Flink 整合 Nacos,動態更改做業配置!

       咱們知道 Flink 做業的配置通常都是經過在做業啓動的時候經過參數傳遞的,或者經過讀取配置文件的參數,在做業啓動後初始化了以後若是再想更新做業的配置通常有兩種解決方法:java  改變啓動參數或者改變配置文件,重啓做業,讓做業可以讀取到修改後的配置  經過讀取配置流(須要自定義 Source 讀取配置),而後流和流鏈接起來        這兩種解決方法通常是使用的比較多,對於第一種
相關文章
相關標籤/搜索