Hi,
确实是一共三个分区，只有一个分区有数据，已经解决，谢谢。
Best,
Junbao Zhang
发件人: Leonard Xu
发送时间: 2020年7月13日 11:57
收件人: user-zh
主题: Re: flink1.10.1 flink sql消费kafka当parallelism大于1时不产生watermark
Hi，
可以先看下 Kakfa topic 对应的partition有几个？是否每个分区都有数据。
祝好，
Leonard Xu
> 在 2020年7月13日，11
Hi，
可以先看下 Kakfa topic 对应的partition有几个？是否每个分区都有数据。
祝好，
Leonard Xu
> 在 2020年7月13日，11:46，wind.fly@outlook.com 写道：
>
> Hi, all：
> 本人使用的flink版本为flink 1.10.1， flink sql消费kafka，
> 当parallelism为1时正常运行，但讲parallelism修改为2时，在yarn-session
> web页面看不到watermark的指标信息了，也没有计算结果输出，sql如下：
> insert into
>
topic是几个分区呢？如果是一个分区，要加一个rebalance参数吧？
wind.fly@outlook.com 于2020年7月13日周一 上午11:46写道：
> Hi, all：
> 本人使用的flink版本为flink 1.10.1， flink sql消费kafka，
> 当parallelism为1时正常运行，但讲parallelism修改为2时，在yarn-session
> web页面看不到watermark的指标信息了，也没有计算结果输出，sql如下：
> insert into
>
Hi, all：
本人使用的flink版本为flink 1.10.1， flink sql消费kafka，
当parallelism为1时正常运行，但讲parallelism修改为2时，在yarn-session
web页面看不到watermark的指标信息了，也没有计算结果输出，sql如下：
insert into
x.report.bi_report_fence_common_indicators
select
fence_id,
'finishedOrderCnt' as indicator_name,
TUMBLE_END(dt, INTERVAL '5'
