我正在开发一个具有无限源的Flink管道。如何在不调用外部服务的情况下，从管道代码内部优雅地关闭管道，以便检查点等工作？System.exit()似乎太粗糙，在启用重新启动的情况下抛出异常将不起作用。(我正在取消源，但这并没有关闭管道，因为源是未绑定的。(
尝试使用savepoint：https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/cli/#terminating-一份工作。
您可以使用保存点停止流式处理作业。稍后，如果您想恢复流式处理作业，请从保存点重新启动它。