开发者社区

文档建议反馈控制台

文章/答案/技术大牛

发布

社区首页 >问答首页 >Flink:管道如何优雅地关闭自身？

问Flink:管道如何优雅地关闭自身？
EN

Stack Overflow用户

提问于 2021-11-17 10:48:34

回答 1查看 67关注 0票数 0

我正在研究一个具有无限源码的Flink管道。如何从管道代码内部优雅地关闭管道，以便检查点等工作，而不调用外部服务？System.exit()似乎太粗糙了，在启用重启的情况下抛出异常将不起作用。(我正在取消源代码，但这不会关闭管道，因为源代码是未绑定的。)

flink-streaming

EN

回答 1

Stack Overflow用户

发布于 2021-11-18 02:30:51

尝试使用savepoint：https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/cli/#terminating-a-job。

您可以使用savepoint停止流式作业。稍后，如果要恢复流作业，请从保存点重新启动它。

票数 2

EN

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/70002965

复制

相似问题