pnowojski commented on issue #6534: [FLINK-10107] [sql-client] Relocate Flink Kafka connectors for SQL JARs URL: https://github.com/apache/flink/pull/6534#issuecomment-433452599 @twalthr what is the problem here? Do I understand this correctly, that different versions of `flink-kafka-connector`s conflicting with one another if they are used/loaded at the same time? And that's potential production issue (however a rare use case), but it's causing problems in our end-to-end tests? If so why would this help: > A perfect solution would be: > > Move version-specific Kafka code into version-specific packages (e.g. o.a.f.kafka10) > Move version-agnostic Kafka code into a common package (e.g. o.a.f.kafka) ? Isn't the correct "perfect" solution to load each connector/plugin in a separate independent class loader, isolated from others?
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
