Flink 重试策略——自定义错误

Question

我们正在使用异步运算符进行 API 调用，有时它们会失败。我们想在一些自定义时间间隔内再次重试同一事件。失败也可能是由于某些 post 调用验证，因此由代码触发。我们发现：https://issues.apache.org/jira/browse/FLINK-11909 不确定这是否已经实施。如果没有，有出路吗？也许在延迟后使用链下的运算符将事件推回异步运算符？或者干脆把需要重试的事件过滤后推回输入流？

Answer 1

目前Flink暂不支持可重试的异步操作。目前最好的解决方案是在您的用户代码中实现重试逻辑。您可以查看 FutureUtils.retry 的示例，了解如何天真地做到这一点。