hello 您好,
    打扰了请教几个问题,:

1.flink窗口的延时数据怎么处理 ,假如我的数据写入kafka或clickhouse,侧输出流可以做到吗?

2.flink怎么做到端到端恰好一次,是不是sink的组件本身得支持恰好一次,clickhouse支持恰好一次吗?

3.flink突然发现之前跑的数据有异常,怎么从之前恢复数据?

4.flink不借助外部组件怎么算日活跃人数(假设数据量还很大)?
5.kafka分区是6个,之前并行度一直给3,最近我数据变大好多,我调整到6,报内存溢出,我把taskmanager的内存也调大2倍,还是不行,居然报了我代码中有些问题,但是我并行度是3是没任何问题的,之前都跑了4个月了
以下是问题5的报错日志?报的是经纬度转省份城市那块,我是在hdfs是维护一个经纬度的region文件,来一条数据就去转


回复