对于缓冲池破坏了异步功能

Question

我在Apache Flink中进行一个项目，我需要调用多个API以实现我的目标。下一个API工作需要每个API的结果。同样，当我在KeyedStream上进行操作时，同样的流程将一次适用于多个数据。

下面的挖掘。可以解释场景

                   /------API1---API2----
   KeyedStream ----|------API1---API2----
                   ------API1---API2----

当我做这一切时，我会发现工作持续了一段时间后，我会说"缓冲池被摧毁"。它是否与API调用有关，我需要使用异步功能吗？请建议。预先感谢。

Answer 1

通常需要一些事情来帮助回答有关flink的问题...

1. 您正在运行什么版本？
2. 您如何运行它(来自IDE，纱线群，独立等(？
3. 什么是完整 stack Trace的例外？
4. (通常(您可以共享您的代码吗？

但是，在高水平上，您提到的"缓冲池破坏"消息不是故障转移的根本原因，它只是Flink的副产品，试图在发生错误后试图杀死工作流程。因此，您需要在日志中进行更深入的挖掘(通常是任务管理器日志首先查看的位置(。