flinksql诡异问题,诡异很诡异!
感谢叶师傅的答复! 这些因素我们也在排查问题是进行过校验和排除: 1.关于数据质量问题,提供的两个sql语句,使用的是同一份数据,不同的只是第一个sql多4个count聚合,包过聚合条件和过滤条件均一致;所以我们排除数据重复问题、数据缺失问题;额外补充一点,第一个sql用flinksql执行出来结果异常,但是用sparksql执行出来的结果是正常的; 2.关于sql语句问题,第一个执行出现异常的sql,在发生异常以前,执行结果都是正常; 3.关于执行流程和系统配置问题:两个语句都是在同一个工具中,提交到同一个环境执行生成,提交时的配置项都一致;
我们当前判断是当天的某一个数据,触发了某个flink的bug,导致返回异常的情况; 但当前我们无法排查出这个数据内容; 查看flink的执行日志,也没有发现报错情况。
赞0
踩0