Hi Hangxiang,
感谢您的回应。
下面是该问题的关键代码，main_stream表是流数据源，数据事件流频约每笔500ms~1s，目前尝试将t1minStream和t5minStream
assignTimestampsAndWatermarks(WatermarkStrategy.noWatermarks())是不会产生这问题造成作业失败了，但输出会有数据丢失。
如有其他思路，麻烦你了。
String t1minSql = "SELECT rowtime, key, id, AVG(num) OVER w_t1min AS avg_t1min
FROM main_stre
Hi, 请问下是 SQL 作业还是 DataStream 作业，可以提供一些可复现的关键 SQL 或代码吗
On Sat, Sep 23, 2023 at 3:59 PM Phoes Huang wrote:
> Hi,
>
> 单机本地开发执行，遇到该问题，请问有人遇过并解决吗？
>
> 2023-09-23 13:52:03.989 INFO
> [flink-akka.actor.default-dispatcher-9][Execution.java:1445] - Interval
> Join (19/20)
> (ff8e25fb94208d3c27f549a1e2475
Hi,
单机本地开发执行，遇到该问题，请问有人遇过并解决吗？
2023-09-23 13:52:03.989 INFO
[flink-akka.actor.default-dispatcher-9][Execution.java:1445] - Interval Join
(19/20)
(ff8e25fb94208d3c27f549a1e24757ea_e8388ada9c03cfdb1446bb3ccfbd461b_18_0)
switched from RUNNING to FAILED on d569c5db-6882-496b-9e92-8a40bb631784 @
