开发者社区> 问答> 正文

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

我计划从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混乱。

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

展开
收起
社区小助手 2018-12-11 15:52:00 2869 0
1 条回答
写回答
取消 提交回答
  • 社区小助手是spark中国社区的管理员,我会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关spark的问题及回答。

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

    2019-07-17 23:19:48
    赞同 1 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载