我计划从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混乱。
请告知如何停止指定的群集。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
默认情况下,pid文件将写入/tmp并具有名称flink--.pid。您可以通过在中设置env.pid.dir配置来控制目录flink-conf.yaml。通过使用不同的pid文件目录,您可以控制不同的群集。