咨询yarn session 集群启动后在不重启的情况下如何更新一个jar包

[wdmcode <wd...@aliyun.com.INVALID>]

hi all
我在yarn集群使用yarn session方式启动了一个flink集群。集群中有一些自定义的Connector。自定义的Connector Jar包放在本地的lib目录。
我如何在不重启yarn session集群的情况下更新一个Connector呢。如果重启yarn session集群会导致所有任务都要重启。但是更新一个Connector只会影响部分任务。

回复：咨询yarn session 集群启动后在不重启的情况下如何更新一个jar包

[17610775726 <17...@163.com>]

Hi wdmcode
看上去 per-job 或者 application 模式更适合你，session 模式的话是需要重启集群才能识别到新添加的 connector。




Best
JasonLee


---- 回复的原邮件 ----
| 发件人 | wdmcode<wd...@aliyun.com.INVALID> |
| 发送日期 | 2023年03月14日 17:59 |
| 收件人 | user-zh<us...@flink.apache.org> |
| 主题 | 咨询yarn session 集群启动后在不重启的情况下如何更新一个jar包 |

hi all
我在yarn集群使用yarn session方式启动了一个flink集群。集群中有一些自定义的Connector。自定义的Connector Jar包放在本地的lib目录。
我如何在不重启yarn session集群的情况下更新一个Connector呢。如果重启yarn session集群会导致所有任务都要重启。但是更新一个Connector只会影响部分任务。

Re: 咨询yarn session 集群启动后在不重启的情况下如何更新一个jar包

[Shammon FY <zj...@gmail.com>]

Hi

如果自定义的connector是和作业打包在一起提交的，那可以可以只重启指定作业就可以了；如果这些connector是在flink
session集群启动时加载的，一般最好重启集群，避免不同版本connector冲突

Best,
Shammon FY

On Tue, Mar 14, 2023 at 5:59 PM wdmcode <wd...@aliyun.com.invalid> wrote:

>
> hi all
> 我在yarn集群使用yarn session方式启动了一个flink集群。集群中有一些自定义的Connector。自定义的Connector
> Jar包放在本地的lib目录。
> 我如何在不重启yarn session集群的情况下更新一个Connector呢。如果重启yarn
> session集群会导致所有任务都要重启。但是更新一个Connector只会影响部分任务。
>