我正在ApacheFlink中做一个项目，需要调用多个API来实现我的目标。每个api的结果都是下一个api工作所必需的。同样，当我在keyedstream上执行此操作时，相同的流将同时适用于多个数据。
在下面挖。你能解释这个场景吗
/------API1---API2----
KeyedStream ----|------API1---API2----
\------API1---API2----在我执行所有这些操作时，在作业运行一段时间后，我收到一个异常消息“缓冲池已销毁”。是否与api调用有关，是否需要使用异步函数？？请建议。提前谢谢。
1条答案
按热度按时间k4emjkb11#
一些事情通常需要帮助回答有关Flink的问题。。。
你在运行什么版本？
您是如何运行它的（从ide、yarn cluster、单机版等）？
异常的完整堆栈跟踪是什么？
（经常）你能分享你的代码吗？
但在较高的层次上，您提到的“buffer pool destromed”消息并不是故障转移的根本原因，它只是flink在发生错误后试图终止工作流的副产品。因此，您需要深入挖掘日志（通常，任务管理器日志是您首先要查看的地方）。