下面是我的keyedprocessfunction中的日志 processElement : 2020-09-16 11:40:54,646 DEBUG com.foo.analysis.FooAnalysis [] - [4750322][START] pp : (onStreamSeq=4750322, onBackupStreamSeq=null, ppSeq=2450, contextCollectTime=2020-09-16T11:39:50.866null[Asia/Seoul]) 可以看到，这个元素是在 2020-09-16 11:40:54,646 但是你可以发现，接下来的收集时间是 2020-09-16T11:39:50.866 在数据源和进程函数之间有将近60秒的时间。
我不知道怎样才能找出是什么原因造成了这么长的延误？