jameswang
jameswang
场景流量分析那个页面不能 其它的可以
我这里是对应的t_session_event_sankey 这个表没有数据 t_session_event_distinct_sankey 这个有 可能需要排查一下代码 只传excel的话 不能支撑大点的数据量
类ExcuteSessionSplitTask saveBatchSessionEventEntity这里应该有点问题 是需要改成ck之类的 才能使用
我也遇到了同样的问题,看官方的文档和代码似乎是在checkpoint时保存批数据以及其label，在checkpoint完成后的第一次invoke中阻塞flush所有缓存在state当中的数据。但我发现在close方法中也进行了flush，我修改了StarRocksSinkManager的close方法，清除掉缓存数据，在flink重启的情况下观察数据是平稳的。