Re: flink时间窗口

[Congxian Qiu]

Hi

对于这个问题，可以尝试看添加相关日志能否在线上（或者测试环境）排查，另外可以使用 watermark 相关的 metric[1] 查看下是否符合预期
如果上面的不行，可以尝试看能否在 IDE 中进行复现，这样可以 debug 进行追查

[1]
https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html#io
Best,
Congxian


忝忝向仧 <153488...@qq.com> 于2020年7月9日周四 下午11:36写道：

> new ProcessWindowFunction是怎么处理的?
> 是否设置了水印?
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:
>                                                   "user-zh"
>                                                                     <
> aichiyuyiy...@163.com&gt;;
> 发送时间:&nbsp;2020年7月9日(星期四) 中午11:37
> 收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
>
> 主题:&nbsp;flink时间窗口
>
>
>
> 你好，我最近业务上需要处理一个流式的时间处理窗口，部分业务代码如下
> SingleOutputStreamOperator<Tuple2<warningPojo, String&gt;&gt; operator =
> flatMap.keyBy(0,1)
> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
> .timeWindow(Time.minutes(1))
> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
> .process(new ProcessWindowFunction)
> 当我运行的时候只有第一分钟的时间窗口会有数据进来，之后便没有数据进来了，业务逻辑代码也没有报错，请问这是什么原因。