为什么stop-cluster.sh会停止最新启动的Flink集群?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

为什么stop-cluster.sh会停止最新启动的Flink集群?

2018-12-11 15:52:00 2278 1

我计划从Flink 1.5.2升级到1.6.0,然后进行作业迁移。为了减少作业的暂停时间,我计划同时运行两个Flink集群,成功迁移作业后,我会停止旧的。但是,当我尝试通过在Flink1.5.2 / bin目录中运行stop-cluster.sh来停止Flink集群时,我发现停止的集群是Flink 1.6.0而不是预期的Flink 1.5.2。

我做了一些测试,发现stop-cluster.sh只是停止了最新启动的Flink集群,也就是说,如果先启动集群1.6.0,然后启动Flink 1.5.2,之后运行stop-cluster。 sh,它会首先停止Flink 1.5.2甚至你在集群1.6.0目录Flink1.6.0 / bin上运行stop-cluster.sh。根据我的理解,当在Flink1.6.0 / bin上运行stop-cluster.sh时,它应该停止集群1.6.0,并在Flink1.5.2 / bin上运行stop-cluster.sh时停止集群1.5.2但它没有。

我做了一些研究,发现stop-cluster.sh会根据包含pid的文件终止进程,但是我不知道该文件的位置,我怀疑两个集群都在同一个pid中编写pid他们开始的地方,这使得stop-cluster.sh混乱。

请告知如何停止指定的群集。

取消 提交回答
全部回答(1)
  • 社区小助手
    2019-07-17 23:19:48

    默认情况下,pid文件将写入/tmp并具有名称flink--.pid。您可以通过在中设置env.pid.dir配置来控制目录flink-conf.yaml。通过使用不同的pid文件目录,您可以控制不同的群集。

    1 0
相关问答

0

回答

flink 1.7.2集群异常退出

2021-12-07 13:53:31 190浏览量 回答数 0

1

回答

flink 1.7.2集群异常退出

2021-12-07 13:56:08 343浏览量 回答数 1

1

回答

Flink CDC中的CDC是什么意思?

2022-01-19 15:15:09 4566浏览量 回答数 1

1

回答

有关 Flink CDC 的介绍和教程可以在哪里参考到?

2022-01-19 16:35:16 1532浏览量 回答数 1

1

回答

Flink CDC 的下游支持了哪些数据源?

2022-01-19 16:09:35 763浏览量 回答数 1

1

回答

Flink CDC 和 Flink 的版本对应关系是怎么样的?

2022-01-19 16:25:14 1264浏览量 回答数 1

1

回答

Flink CDC 的亮点之一是什么?

2022-01-19 16:21:12 607浏览量 回答数 1

1

回答

Flink CDC 的核心特性有哪些?

2022-01-19 16:17:42 597浏览量 回答数 1

1

回答

flink 1.11 cdc相关问题

2021-12-07 10:07:48 700浏览量 回答数 1

1

回答

Flink1.11支持CDC了是么? #Flink

2020-06-10 23:24:45 1720浏览量 回答数 1
+关注
社区小助手
社区小助手是spark中国社区的管理员,我会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关spark的问题及回答。
文章
问答
问答排行榜
最热
最新
相关电子书
更多
《基于 Flink 的全新 Pulsar Connector 的设计、开发和使用》
立即下载
HBase 高可用HA
立即下载
Flink State & Fault Tolerance
立即下载