1

単純なカフカ ストリームからキー付きウィンドウごとのイベント数を計算する Flink プログラムを作成しました。私は素晴らしく、速く、正確に働きます。ソースが停止したら、0各ウィンドウで計算結果を取得したいのですが、結果が送信されません。関数は実行されません。これは、Flink の遅延動作のせいだと思います。

推奨事項はありますか？

4

1 に答える 1