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

Tue, 13 Oct 2020 20:53:03 -0700 

hello,

stenv.fromDataStream(stream, $"")
请教下，如果stream中数据是org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode
类型，field应该如何设置呢?
比如：
{
 a: 1,
 b: {
  c: "test"
 }
}

Best Wishes.

shizk233 <[email protected]> 于2020年9月28日周一 下午7:15写道：

> 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及以上，数据无法输出
>

回复