2017-06-04 6 views
0

以下の記事から、非キーストリームの場合の並列性は1であることが分かっているので、setParallelismによって並列性を高めることができますか? "キーが入力されていないストリームの場合、元のストリームは複数の論理ストリームに分割されず、すべてのウィンドウロジックは1つのタスク、つまり並列性1で実行されます。すぐにすべてのウィンドウ演算子内のストリームのオペレーターに1とは異なる値を設定するsetParallelismを使用しようとするとsetParallelismによって非キーウィンドウの並列性を上げることはできますか?

https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/windows.html#keyed-vs-non-keyed-windows

答えて

0

、例外がスローされます。 forceNonParallelを使用すると、対応する演算子の並列性がオーバーライドできないようにするため、この機能も公開されています。

+0

forceNonParallel [2]は、パラレル化を2に設定することを意味しますか?しかし、Apiドキュメントのdescから "forceNonParallel wouldこの演算子の並列性と最大並列性を1に設定します"また、並列性パラメータ2または他の数で呼び出すことはできないようです。 –

関連する問題