7

我目前想知道如何处理 Apache Flink 流应用程序中的应用程序错误。一般来说,我看到两种情况:

  1. 暂时性错误,您希望重播输入数据并且处理可能在第二次尝试时成功。一个示例是对暂时不可用的外部服务的依赖。
  2. 永久性错误,重复处理仍会失败;例如无效的输入数据。

对于第一种情况,常见的解决方案似乎只是抛出一些异常。或者有没有更好的方法,例如一种特殊类型的异常,用于更有效地处理,例如FailedException来自 Apache Storm Trident(请参阅Storm Trident 拓扑中的错误处理)。

对于永久性错误,我在网上找不到任何信息。例如,一个map()操作总是必须返回一些东西,因此不能像在 Trident 中那样默默地丢弃消息

有哪些可用的 API 或最佳实践?谢谢你的帮助。

4

1 回答 1

1
于 2020-07-29T07:47:52.083 回答