flink KeyedProcessFunction 优化问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink KeyedProcessFunction 优化问题

星夜
现在在做一个响应时间要求很高的实时项目,使用了KeyedProcessFunction处理单条数据。根据日志打点发现,processElement函数执行用时仅几毫秒,从KeyBy到processElement之间的时间消耗了100多毫秒,请问这个是什么问题,该怎么优化?