如何在实时生产环境中停止flink应用程序而不丢失流数据

kzmpq1sx  于 2021-06-25  发布在  Flink
关注(0)|答案(1)|浏览(380)

我有一个flink应用程序从aws kinesis流读取数据。producer应用程序以每秒600条记录的速率写入kinesis流。
我想知道在实时生产环境中停止flink应用程序的最佳实践是什么,而生产者仍然在向流写入数据而不丢失输入流数据。
我认为有必要停止应用程序进行定期维护、应用程序部署更改等。

8cdiaqws

8cdiaqws1#

您应该使用保存点,它使您能够存储flink应用程序的内部状态,并从该时间点进一步重新启动应用程序。
有关更多信息,请参阅文档

相关问题