apache-flink - Apache Flink 中的 AsyncIO 异常

Question

在 Apache Flink 中，我使用 RichAsyncFunction 来丰富数据。在出现错误/异常的情况下，我想将这些错误记录汇集到错误流中。我可以看到其他函数对于这种场景有一个“侧面输出”，但它在 RichAsyncFunction 中是如何处理的？我还看到了 ResultFuture<>.completeExceptionally 的使用，但是当它发生时，这意味着什么？流是否停止，是否刚刚记录，流的输出元素的状态是什么？所有文档似乎都只是指出如何处理快乐路径或调用 completeExceptionally ，而没有解释接下来会发生什么。在 RichAsyncFunction 中处理/捕获错误的正确方法是什么？

谢谢！

标签： apache-flink