Re: flink 1.11.2 Table sql聚合后设置并行度为2及以上，数据无法输出

Mon, 28 Sep 2020 04:16:04 -0700 

flink sql似乎不能设置rebalance，在Data Stream API可以设。

一种思路是拆分sql逻辑，在Data Stream API上创建kafka source后再reblance成一张新表，再做后续dml sql。

另一种思路就是kafka topic增加一下分区

Asahi Lee <[email protected]> 于2020年9月28日周一 下午1:56写道：

> 你好！     使用flink
> SQL，如何设置rebalance呢？------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:&nbsp;&quot;zilong&amp;nbsp;xiao&quot;<[email protected]&gt;
> 发送时间:&nbsp;2020年9月27日(星期天) 晚上6:27
> 收件人:&nbsp;&quot;user-zh&quot;<[email protected]&gt;;
> 主题:&nbsp;Re: flink 1.11.2 Table sql聚合后设置并行度为2及以上，数据无法输出

回复