如何将我的流程的新更改部署到 Apache Flink 集群？
How to deploy new changes of my flow to Apache Flink cluster?
例如，我使用流程上传了 JAR，并通过 Apache Flink 仪表板 运行 上传了它。然后我实现了一些流程上的变化，想部署它们。
任何人都可以逐步向我解释如何将新版本的流正确部署到 Apache Flink 集群（没有停机、丢失状态等）吗？我在官方文档中没有找到部署过程的描述。
你要用的是Flink中的savepoints。
步骤如下：
- 为您的工作准备新的 jar
- 使用
flink savepoint <JobID> 保存当前 运行 作业的状态
- 停止作业
- 使用刚刚创建的保存点启动新的 jar
flink run -s <pathToSavepoint> <jobJar> ...
另请参阅：https://www.ververica.com/blog/how-apache-flink-enables-new-streaming-applications-part-1
例如，我使用流程上传了 JAR，并通过 Apache Flink 仪表板 运行 上传了它。然后我实现了一些流程上的变化，想部署它们。
任何人都可以逐步向我解释如何将新版本的流正确部署到 Apache Flink 集群（没有停机、丢失状态等）吗？我在官方文档中没有找到部署过程的描述。
你要用的是Flink中的savepoints。
步骤如下：
- 为您的工作准备新的 jar
- 使用
flink savepoint <JobID> 保存当前 运行 作业的状态
- 停止作业
- 使用刚刚创建的保存点启动新的 jar
flink run -s <pathToSavepoint> <jobJar> ...
另请参阅：https://www.ververica.com/blog/how-apache-flink-enables-new-streaming-applications-part-1