当前位置: 首页 > 知识库问答 >
问题:

我们可以通过setParallelism增加非键控窗口的并行性吗?

戎鹏云
2023-03-14

从下面的文章中我们知道,对于非键控流,并行度是1,那么我们可以通过setParallelism来增加并行度吗?如果是非键控流,原始流将不会被分割成多个逻辑流,所有窗口逻辑将由单个任务执行,即并行度为1

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

共有1个答案

东郭元魁
2023-03-14

只要您尝试使用setParallelism在All Window运算符中的流运算符上设置不同于1的值,就会引发异常。此功能也会公开,因为您可以使用forceNonParallel来确保相应运算符的并行性不会被重写。

 类似资料:
  • 问题内容: 我正在尝试读取一个自定义(非标准)CSS属性,该属性在样式表(而非内联样式属性)中设置并获取其值。以这个CSS为例: 我已经设法通过IE7中的currentStyle属性获取其值: 但是currentStyle是特定于MS的。所以我在Firefox 3和Safari 3中尝试了getComputedStyle(): …并且返回未定义。 有谁知道跨浏览器的方法来获取自定义CSS属性值?

  • 问题内容: 我的要求: 确定的前10个帐户,并按帐号升序排列。 询问: 痕迹: 指数: 该说,在列。 强制扫描的费用从3855降低至11092 表中的总行数为632667; 以上都是测试区域的结果。生产实际上是数量的两倍。 我的数据库是Exadata,Quarter RAC。运行Oracle 11g R2。该数据库功能强大到可以立即执行,但是DBA不愿使用13M的tempSpc。商业报告该报告的频

  • 问题内容: 给定:int x [3] = {11,22,33}; 如何将其作为键值保存为二进制数据并获取 hiredis提供了有关如何设置二进制安全字符串的示例 但是其他数据又如何获取呢? 问题答案: 将二进制数据直接存储在远程存储中而不进行任何编组处理是灾难的根源。我不建议这样做:可以使用许多序列化协议来使二进制数据独立于平台。 也就是说,回答您的问题: 请注意,只有在确保所有Redis客户端在

  • 我可以在Angular中添加任何属性到窗口对象吗?一些事情,比如: 我尝试使用对象windows bat时出错: 类型“Window”上不存在属性“attr”。

  • 问题内容: 我正在尝试仅使用键盘来放大和缩小Chrome(seleniumwebdriver)。我努力了 - 但它不起作用。需要在python中回答。 问题答案: 我只是为此而苦苦挣扎。我设法找到了对我有用的东西,希望对您有用: 拥有’zoom%’=您想要的任何缩放级别。(例如“ 67%”)

  • 问题内容: 我有下面的代码,我需要做的是通过ajax将href中的图像加载到div中。任何帮助。我相信load()无法加载这样的图像? 非常感谢,C 问题答案: 您还必须删除当前附加的图像。这是带有单击事件和图像的,而不是附加标记的。