Flink SQL 对延迟数据怎么处理？-问答-阿里云开发者社区-阿里云

开发者社区

请教一下，FlinkSQL中，我在创建表时设置了watermark并设置了最大延迟，可是还是有数据依旧会迟到晚到，对于这样的数据我们又不想直接丢弃，那这个依旧迟到的数据我该怎么收集？是否有与StreamAPI一样可以将依旧迟到的数据进行分流的方案？

*来自志愿者整理的flink邮件归档

据我所知，FlinkSQL 不支持将迟到的数据输出到侧流中。如果你下游使用的是 window 的话，可以通过设置 table.exec.emit.late-fire.enabled 和 table.exec.emit.late-fire.delay 来触发晚于 watermark 到达的数据。其中允许等待晚与 watermark 的数据的时间由 table.exec.state.ttl 控制，等价于 Datastream 中的 allowedLateness，故 window 的最大等待时间为 watermark 的 outOfOrder + allowedLateness。

*来自志愿者整理的flink邮件归档

2021-12-06 11:26:58

企业邮箱发送邮件时，若出现投递失败产生退信，内容提示包含如下： the mta server of * reply:550 failed to meet SPF requirements 或者 the mta server of 163.com — 163mx01.mxmail.netease.com(220.181.14.141) reply:550 MI:SPF mx14,QMCowECpA0qTiftVaeB3Cg—.872S2 1442548128 http://mail.163.com/help

302806