如何在不丢失流数据的情况下停止Flink在正式生产环境中的应用
我有一个Flink应用程序从AWS驱动流读取数据。生产者应用程序以每秒600条记录的速率写入Kinesis流。
我想知道在实时生产环境中停止flink应用程序的最佳实践是什么，而生产商仍在向流写入数据，而不会丢失输入流数据。
我认为需要停止应用程序以进行计划维护、应用程序部署更改等。
共有1个答案
您应该使用保存点，它使您能够存储flink应用程序的内部状态，并从该时间点进一步重启应用程序。
有关更多信息，请参阅文档
-
问题内容： 我想实现一个可以使用flask-script停止flask应用程序的命令。我已经搜索了一段时间。因为该框架不提供“ app.stop（）” API，所以我对如何编写此代码感到好奇。我正在使用Ubuntu 12.10和Python 2.7.3。 问题答案： 如果仅在桌面上运行服务器，则可以公开终结点以终止服务器: 这是另一种包含更多的方法： 让我知道是否有帮助。
-
问题内容： 我想实现一个可以使用flask-script停止flask应用程序的命令。我已经搜索了一段时间。因为该框架不提供“ app.stop（）” API，所以我对如何编写此代码感到好奇。我正在使用Ubuntu 12.10和Python 2.7.3。 问题答案： 如果您只是在桌面上运行服务器，则可以公开终结点以终止服务器（有关更多信息，请参见Shutdown The Simple Server
-
我安装了一个HBase，其中有一组现有表，其中有一组数据（我不想删除）。最近，我偶然发现使用Apache Phoenix可以使用类似SQL的语法查询HBase数据，到目前为止，这非常棒。然而，由于我仍然不完全熟悉各种数据类型以及它们如何映射到我存储在HBase中的Java类型，有时我会弄错。如果我有一个存储为的HBase列 我不小心将我的Phoenix列创建为varchar，我现在如何在不丢失所有
-
问题内容： 我有以下代码： 在发生某些事件之后，我应该停止在的方法中声明的操作，该方法实现。 我怎样才能做到这一点？我无法关闭执行器，只能撤消我的定期任务。我可以用吗？如果可以的话，请告诉我它将如何工作。 问题答案： 使用。该是你的任务的处理。您需要取消此任务，它将不再执行。 实际上，是签名，并将其与参数一起使用将导致当前正在运行的执行线程被调用中断。如果线程在阻塞的可中断调用（例如）中等待，则会
-
问题内容： 我在Docker容器上安装了Nginx，并且正在尝试像这样运行它： 问题在于Nginx的工作方式，即初始进程会立即产生一个主要的Nginx进程和一些工作程序，然后退出。由于Docker仅监视原始命令的PID，因此容器将暂停。 如何防止容器停止？我需要能够告诉它绑定到第一个子进程，或者阻止Nginx的初始进程退出。 问题答案： 像所有行为良好的程序一样，可以配置为不自我守护。 使用htt
-
RT,大表，随时都有数据的读写