SQL 处理延时数据

[张普]

hi,
 目前场景是： 输出的下游服务经常挂掉，导致数据堆积，任务重启之后数据乱序程度变大导致很多数据丢失，业务想拿到这部分丢失的数据，目前是使用SQL的方式，所以想
   如何通过flink Stream SQL /Table API 处理延时数据呢，希望不通过转换成为DataStream方式， thanks!






祝生活愉快！
张普
联系电话：[phone]
邮箱:[hidden email]