1

自分で修正した wordcount サンプルを実行すると、Flink 0.9.0 リリースで問題が発生しました。count ウィンドウが公式ドキュメントとは異なるローカルウィンドウの振る舞いをしていることがわかりました。また、 https://issues.apache.org/jira/browse/FLINK-1657で修正されたバグも見つけました。正解はどれ？どんな助けでも大歓迎です！どうもありがとうございます

4

2 に答える 2

1

ウィンドウを適用する前にグループ化する必要があります。

dataStream.flatMap(new WordCount.Tokenizer()).groupBy(0).window(Count.of(8)).every(Count.of(4)).sum(1).‌​flatten().print()

カウント ウィンドウはローカルで組み立てられます (私の知る限り)。現在、Flink は順序付けを保証していないため、カウント ウィンドウをローカルに構築すると最高のパフォーマンスが得られます。

于 2015-07-21T08:39:49.200 に答える