トライデント バッチが並行して実行されるかどうか、つまり一度に複数のバッチを実行できるかどうかを知りたいです。
これとは別に、個別に投稿するには小さすぎる質問がいくつかあります。それらが十分に大きい場合は、コメントして個別に投稿してください。
バッチ内の特定のタプルのみの処理が失敗した場合はどうなりますか?
その後、バッチが再生され、以前に正常に処理されたタプルが再処理されますか? たとえば、単語カウントでは、すべてのタプルに単語が含まれていますが、正常にカウントされたタプルはわずかでしたか? たとえば、manという単語が 3 つあり、カウントが 2 しかない場合、1 つのタプルが処理に失敗したことを意味しますか?
このチュートリアルでのみ、以前のtxidが保存されます。以前のトランザクション ID はどうですか?
たとえば、3 つのバッチ 1、2、3、4 があります。ここで、バッチ #1、#2 が実行された後、バッチ #1 が再生されます。その場合、txid は 2 になります。これは、最後に処理されたバッチがバッチ #2 であり、バッチ #1 が以前に処理されたかどうかを認識する方法がないためです。その場合、バッチは順番に実行する必要があります。つまり、バッチ #1 が正常に終了するまで、バッチ #2 を実行できません。その場合、バッチを実行する際の並列処理はどこにありますか?
トポロジ内のバッチで特定の機能だけが正しく実行されない場合はどうなりますか?
たとえば、メッセージをデータベースに永続化する機能と、kafka キューに生成する機能の 2 つの機能があります。ここでは、データベースへの永続化は成功していますが、いくつかのノード障害 (たとえば) が原因で、kafka キューへのプッシュは失敗しています。次に、その特定のバッチに対して実行される kafka キューにプッシュする関数のみが必要です。トライデントで行う方法はありますか？このために、txid だけでなく、その txid に対して処理される関数のリストも保存する必要があります。どうすればそれができますか？