Flink这个问题怎么解决？

Flink这个问题怎么解决？我们使用sql聚合函数生成指标出现偶发性部分指标异常。使用spark sql跑指标正常的。确定是某一天的数据触发了异常。下的sql前面4个指标正常，后面全是1

select
country_id,
joke_type,
sc_type,
sc_version,
count(distinct userid) user_cnt,
count(distinct subserial) dev_cnt,
count(distinct concat(subserial,cn)) channel_cnt,
count(distinct hd) hd_cnt,
count(1) all_cnt,
count(case when r not in (-1,-2,21,20084,25404,25409,25416,25451,25544,25546,26109,10053,10057,10121,10122,10125,10127) then 1 end) all_cnt_qu,
count(case when r = 0 then 1 end) success_cnt,
count(case when r = 0 and flowt between 0 and 30000 then 1 end) success_cnt2,
sum(case when r = 0 and flowt between 0 and 30000 then flowtbt else 0 end) flowtbt,
sum(case when r = 0 and flowt between 0 and 30000 then flowtht else 0 end) flowtht,
sum(case when r = 0 and flowt between 0 and 30000 then flowtot else 0 end) flowtot,
sum(case when r = 0 and flowt between 0 and 30000 then decodet else 0 end) decodet,
sum(case when r = 0 and flowt between 0 and 30000 then flowt else 0 end) flowt,
sum(case when r = 0 and flowt between 0 and 30000 then viewt else 0 end) viewt
from dwa.test_table
where dt = '2023-08-17'
group by
country_id,
joke_type,
sc_type,
sc_version;