at org.apache.flink.streaming.api.datastream.ConnectedStreams.transform(ConnectedStreams.java:366)at org.apache.flink.streaming.api.datastream.ConnectedStreams.process(ConnectedStreams.java:339)at org.apache.flink</
在我的flink作业中,我将数据保存在mapstate中几分钟,以便进一步处理,在process元素中,我需要在mapstate值的帮助下执行一组操作,所以我在mapstate内容的帮助下使用多个线程进行处理线程没有修改状态,它只获取导致CocurrentModification异常的键值,这个TTL异常也出现在COnfigured TTL时间之前,日志如下。:470)
at org.apache</