guoweiM commented on issue #11247: [FLINK-16262][Connectors] Set the context classloader for parallel stream in FlinkKafkaProducer URL: https://github.com/apache/flink/pull/11247#issuecomment-602170216 In theory, the current `StreamingKafkaITCase` would cover the problem. But the case does not reproduce the issue. I test two situations to verify the classloader that `parallelStream`'s threads use. - The session mode - Per-Cluster mode. All the two situations show that the `parrallelStream`'s threads use the `ChildFirstClassLoader`. If there is no other concern I think we could reuse the current case to verify this change. @pnowojski BTW: I think maybe some static class initializes the `parrallelStream`'s threads with system classloader when TM starts. But I have not any clue yet.
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
