注文したストリームのFlink保証

Question

Flinkでの私の小さな経験から、注文後に到着する予定があっても、注文後に到着するはずです。これは、ここで議論されています

1. keyBy機能はまだ私には不明である後の順序が失われた理由：Ordering of Records in Stream

   は、だから私は、上記の質問を拡張する3つの質問を持っています。なぜそれが起こるのですか？

2. パーティショニング後もイベントの順序を保証する手段はありますか？

3. KeyedStreamsを作成しない場合、並列演算子ごとにイベントの順序が保証されていますか？

Answer 1

ここでは誤解があるかもしれないと思います。

同じキーで同じ演算子から放出された要素の要素の順序は保持されます。ただし、パーティション分割後の受信側では、受け取ったキーと同じキーを持つすべてのレコードを考慮する場合は、パラレル演算子ごとに順序が保証されているため、厳密な順序はありません。