小贝子编程

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



我有一个 flink 应用程序从 AWS Kinesis Stream 读取数据。创建者应用程序以每秒 600 条记录的速率写入 Kinesis 流。

我想知道在实时生产环境中停止 flink 应用程序的最佳实践是什么，而生产者仍在写入流而不丢失输入流数据。

我看到需要停止应用程序以进行计划维护、应用程序部署更改等。

你应该使用保存点，它使您能够存储 flink 应用程序的内部状态，并从该时间点进一步重新启动应用程序。

有关详细信息，请参阅文档

相关内容

最新更新


热门标签：

javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium