如何将流程的新变化部署到Apache Flink集群？

Question

例如，我在流程中上传了JAR，并通过Apache Flink仪表板运行它。然后，我对流程进行了一些更改，并希望部署它们。

谁能一步一步地向我解释如何将我的流程的新版本正确地部署到Apache Flink集群（不造成停机，状态丢失等）？我没有在官方文档中找到有关部署过程的描述。

Answer 1

您要使用的是Flink中的保存点。

步骤如下：

• 为您的工作准备新的罐子
• 使用以下命令保存当前正在运行的作业的状态 flink savepoint <JobID>
• 停止工作
• 使用刚刚创建的保存点启动新的jar flink run -s <pathToSavepoint> <jobJar> ...

另请参阅：https : //www.ververica.com/blog/how-apache-flink-enables-new-streaming-applications-part-1