jobmanager 开启ha模式重复启用的问题

2023-10-20 Thread s
flink onYarn集群,运行模式为yarn application
开启zookeeper  high 
availability后,JobManager由于异常退出后,会重新启动一个jm在其他节点,这个没有问题,但是之前的那个tm的信息在zk中并不会删除,导致出现了两个job在,并且后续启动的那个job长期属于悬挂状态,不会正常工作
flink 版本为1.15.3,日志中的错误如下:


页面上的现象如下:


zk中的状态看上tm的信息不会删除,仍然是被locks的状态






请教下各位,是否有遇到类似的情况,zk中的过久信息是否可以配置删除?



回复: flink sql不支持show create catalog 吗?

2023-10-20 Thread 李宇彬
Hi Feng


我之前建过一个jira(https://issues.apache.org/jira/browse/FLINK-24939),引入CatalogStore后,实现这个特性的时机应该已经成熟了,我们这边业务场景里用到了很多catalog,管理起来很麻烦,有这个特性会好很多。
| |
 回复的原邮件 
| 发件人 | Feng Jin |
| 发送日期 | 2023年10月20日 13:18 |
| 收件人 |  |
| 主题 | Re: flink sql不支持show create catalog 吗? |
hi casel


从 1.18 开始,引入了 CatalogStore,持久化了 Catalog 的配置,确实可以支持 show create catalog 了。


Best,
Feng

On Fri, Oct 20, 2023 at 11:55 AM casel.chen  wrote:

之前在flink sql中创建过一个catalog,现在想查看当初创建catalog的语句复制并修改一下另存为一个新的catalog,发现flink
sql不支持show create catalog 。
而据我所知doris是支持show create catalog语句的。flink sql能否支持一下呢?