Flink 动态更新配置，不需要重启作业

谁借莪１个温暖的怀抱￠ 2021-09-20 14:46 899阅读 0赞

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

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

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

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

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

Flink  open 方法

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzI5MTA1NQ_size_16_color_FFFFFF_t_70][]

invoke 方法：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzI5MTA1NQ_size_16_color_FFFFFF_t_70 1][] 日志打印结果：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzI5MTA1NQ_size_16_color_FFFFFF_t_70 2][]

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

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzI5MTA1NQ_size_16_color_FFFFFF_t_70]: /images/20210920/7855d1e5416b4b1d89c17c3488344f9f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzI5MTA1NQ_size_16_color_FFFFFF_t_70 1]: /images/20210920/600d43fb74d44f73a3b95c9a9c5f098e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzI5MTA1NQ_size_16_color_FFFFFF_t_70 2]: /images/20210920/5bc2fac42af94098aadf2cf782bed488.png

发表评论取消回复

表情：

评论列表（有 0 条评论，899人围观）

还没有评论，来说两句吧...

相关阅读

相关 Flink的重启策略

Flink重启策略

忘是亡心i/ 2024年04月28日 13:04/ 0 赞/ 11 阅读

相关 springcloud config 修改配置文件@RefreshScope不需要重启项目

1. 修改pom <dependency> <groupId>org.springframework.boot</groupId>

刺骨的言语ヽ痛彻心扉/ 2022年12月29日 15:30/ 0 赞/ 268 阅读

相关 flink 相关container异常导致作业重启

1、错误信息如下： 2021-02-01 13:44:47 org.apache.flink.util.FlinkException: The assigne

我就是我/ 2022年10月26日 01:24/ 0 赞/ 147 阅读

相关 Solr 热更新，不重启修改配置文件

单机部署如果Solr是部署在Jetty等WEB容器中的话，需要容器本身支持，大部分情况下，支持是不好的。 SolrCould部署在对schema.xml进行修

向右看齐/ 2022年06月08日 13:22/ 0 赞/ 429 阅读

相关 Flink（十）Flink的重启策略

Flink的重启策略 Flink支持不同的重启策略，这些重启策略控制着job失败后如何重启。集群可以通过默认的重启策略来重启，这个默认的重启策略通常在未指定重启策略的情况

偏执的太偏执、/ 2022年02月04日 09:21/ 0 赞/ 377 阅读

相关 Flink重启策略

Flink重启策略 Flink支持不同的重启策略，可以控制在发生故障时如何重启新启动作业。默认重启策略是通过Flink的配置文件设置的`flink-conf.yaml

Love The Way You Lie/ 2021年12月24日 03:27/ 0 赞/ 245 阅读

相关 Flink重启策略

Flink重启策略 Flink支持不同的重启策略，可以控制在发生故障时如何重新启动作业。可以使用默认重新启动策略启动集群，该策略在未定义任何特定于作业的重新启动策略

迈不过友情╰/ 2021年11月16日 09:24/ 0 赞/ 326 阅读

相关修改代码不需要重启Tomcat

代码更改时，不想让Tomcat重新跑，更改server.xml <Context docBase="D:\\apache\\apache-tomcat-7.0.85-w

深碍√TFBOYSˉ_/ 2021年09月28日 06:40/ 0 赞/ 358 阅读

相关 Flink 动态更新配置，不需要重启作业

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

谁借莪１个温暖的怀抱￠/ 2021年09月20日 14:46/ 0 赞/ 900 阅读

相关 Mycat更新配置不重启

mycat更新配置不重启的方式，重启会导致之前的mysql链接失效，客户端会出现异常。首先修改conf下的配置文件，需要更新配置操作如下 1.连接到mycat的9066端

蔚落/ 2021年09月01日 07:16/ 0 赞/ 756 阅读