在缓冲池被破坏的情况下，异步函数是否有用？

Question

我正在 apache flink 中做一个项目，我需要调用多个 API 以实现我的目标。每个 API 的结果是下一个 API 工作所必需的。同样，当我在 KeyedStream 上执行此操作时，相同的流程将同时适用于多个数据。

下面挖。可以解释一下场景

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

在执行所有这些操作时，在作业运行一段时间后出现“缓冲池已损坏”的异常。是否与API调用有关，我需要使用异步函数吗？请建议。提前致谢。

Answer 1

帮助回答有关 Flink 的问题通常需要的一些东西...

1. 您运行的是什么版本？
2. 您是如何运行它的（从 IDE、YARN 集群、独立等）？
3. 异常的完整堆栈跟踪是什么？
4. （经常）你能分享你的代码吗？

但是从高层次上讲，您提到的“缓冲池被破坏”消息并不是故障转移的根本原因，它只是 Flink 在发生错误后试图终止工作流的副产品。因此，您需要深入挖掘日志（通常任务管理器日志是您首先查看的位置）。