如何在不丢失流数据的情况下停止现场生产环境中的 Flink 应用程序
How to stop Flink application in live production environment without loosing streaming data
我有一个 flink 应用程序从 AWS Kinesis Stream 读取数据。生产者应用程序以每秒 600 条记录的速度写入 Kinesis 流。
我想知道当生产者仍在写入流而不丢失输入流数据时，在实时生产环境中停止 flink 应用程序的最佳实践是什么。
我看到需要停止应用程序以进行定期维护、应用程序部署更改等
你应该使用保存点，它使你能够存储你的 flink 应用程序的内部状态，并从那个时间点进一步重启你的应用程序。
有关详细信息，请参阅 docs
我有一个 flink 应用程序从 AWS Kinesis Stream 读取数据。生产者应用程序以每秒 600 条记录的速度写入 Kinesis 流。
我想知道当生产者仍在写入流而不丢失输入流数据时，在实时生产环境中停止 flink 应用程序的最佳实践是什么。
我看到需要停止应用程序以进行定期维护、应用程序部署更改等
你应该使用保存点，它使你能够存储你的 flink 应用程序的内部状态，并从那个时间点进一步重启你的应用程序。
有关详细信息，请参阅 docs