【发布时间】:2017-06-04 11:16:24
【问题描述】:
从下面的文章中我们知道非键流的并行度为 1,那么我们可以通过 setParallelism 增加并行度吗? “在非键控流的情况下,您的原始流不会被拆分为多个逻辑流,并且所有窗口化逻辑都将由单个任务执行,即并行度为 1。”
【问题讨论】:
标签: apache-flink flink-streaming
从下面的文章中我们知道非键流的并行度为 1,那么我们可以通过 setParallelism 增加并行度吗? “在非键控流的情况下,您的原始流不会被拆分为多个逻辑流,并且所有窗口化逻辑都将由单个任务执行,即并行度为 1。”
【问题讨论】:
标签: apache-flink flink-streaming
一旦您尝试使用setParallelism 为 All Window 运算符中的流的运算符设置不同于 1 的值,就会引发异常。这个功能也暴露了,你可以使用forceNonParallel保证对应算子的并行度不会被覆盖。
【讨论】: