You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 沉醉寒風 <10...@qq.com> on 2021/01/29 09:41:41 UTC
回复： 未生成水位线
有的
kafka 是3个分区, 但是只有一个分区有数据, flink是3个并行度
------------------ 原始邮件 ------------------
发件人: "user-zh" <wjxdtc10530@gmail.com>;
发送时间: 2021年1月29日(星期五) 下午5:30
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: 未生成水位线
看一下 WaterMarkAssigner节点 是否有 数据流入
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Re: 未生成水位线
Posted by Shuo Cheng <nj...@gmail.com>.
Hello, 注意到你设置了 `table.exec.source.idle-timeout`, 需要注意的是这个参数是 table 层的参数,
需要确认你的设置方式是否生效.
On Fri, Jan 29, 2021 at 5:41 PM 沉醉寒風 <10...@qq.com> wrote:
> 有的
>
>
>
> kafka 是3个分区, 但是只有一个分区有数据, flink是3个并行度
>
> ------------------ 原始邮件 ------------------
> *发件人:* "user-zh" <wj...@gmail.com>;
> *发送时间:* 2021年1月29日(星期五) 下午5:30
> *收件人:* "user-zh"<us...@flink.apache.org>;
> *主题:* Re: 未生成水位线
>
> 看一下 WaterMarkAssigner节点 是否有 数据流入
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>