You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 星夜 <16...@qq.com> on 2021/06/16 10:56:00 UTC

flink KeyedProcessFunction 优化问题

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