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

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

回复: Flink 1.11 jdbc查pg失败

Hi Jimmy 给字段加双引号试试呢 Select “F1”,”F2” from xxx.xxx; 发件人: Jimmy Zhang 发送时间: Thursday, September 10, 2020 9:41 AM 收件人: user-zh@flink.apache.org 主题: Flink 1.11 jdbc查pg失败 flink 1.11用jdbc查询pg表时，pg表的字段是大写 flink会把字段转成小写，而导致查询失败，有大佬知道这个问题吗 Best, Jimmy Signature is customized by Netease Mail Master

回复: flink-cdc sink mysql 问题

Hi 杨帅统 MySQL-MySQL数据实时同步也可以使用阿里开源的otter https://github.com/alibaba/otter/ 发件人: 杨帅统 发送时间: Wednesday, September 9, 2020 4:49 PM 收件人: user-zh@flink.apache.org 主题: flink-cdc sink mysql 问题 公司希望将MySQLA库的数据实时同步到B库中，我想通过fink1.11的CDC功能不知道是否可行。 在做测试的时候定义一张cdc源表和一张sink表 CREATE TABLE pvuv_test ( id INT,