ZhangChaoming commented on pull request #19219: URL: https://github.com/apache/flink/pull/19219#issuecomment-1084169173
@pnowojski `ConcurrentHashMap` uses CAS ranther than ReentrenLock after jdk8, which has good performance in multi-thread condition as well as single condition. > What are the two threads that are causing this concurrent modification exception? I track all the usages of `subclassSerializerCache`, I can not find out the reason. I gess the `subclassSerializerCache.entrySet().stream()` is to blame. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
