Hello, 注意到你设置了 `table.exec.source.idle-timeout`, 需要注意的是这个参数是 table 层的参数, 需要确认你的设置方式是否生效.
On Fri, Jan 29, 2021 at 5:41 PM 沉醉寒風 <1039601...@qq.com> wrote: > 有的 > > > > kafka 是3个分区, 但是只有一个分区有数据, flink是3个并行度 > > ------------------ 原始邮件 ------------------ > *发件人:* "user-zh" <wjxdtc10...@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/ >
