現在、Apache Flink ストリーミング アプリケーションでアプリケーション エラーを処理する方法を考えています。一般に、次の 2 つのケースが見られます。
- 入力データを再生して、2 回目の試行で処理が成功する可能性がある一時的なエラー。例としては、一時的に利用できない外部サービスへの依存があります。
- 永続的なエラー。処理を繰り返しても失敗します。たとえば、無効な入力データです。
最初のケースでは、一般的な解決策は、何らかの例外をスローすることです。FailedExceptionまたは、Apache Storm Tridentなどのより効率的な処理のための特別な種類の例外など、より良い方法はありますか( Storm Trident トポロジでのエラー処理を参照)。
永続的なエラーについては、オンラインで情報を見つけることができませんでした。map()たとえば、操作は常に何かを返す必要があるため、 Trident のようにメッセージを黙ってドロップすることはできません。
利用可能な API またはベスト プラクティスは何ですか? ご協力いただきありがとうございます。