Tzu-Li (Gordon) Tai created FLINK-8741:
------------------------------------------
Summary: KafkaFetcher09/010/011 uses wrong user code classloader
Key: FLINK-8741
URL:
https://issues.apache.org/jira/browse/FLINK-8741 Project: Flink
Issue Type: Bug
Components: Kafka Connector
Affects Versions: 1.5.0, 1.4.1
Reporter: Tzu-Li (Gordon) Tai
Assignee: Tzu-Li (Gordon) Tai
Fix For: 1.5.0, 1.4.2
This commit
https://github.com/apache/flink/commit/0a1ce0060ef3af29b196ab6ad58f97e49a40a4cf#diff-51fb939365cf758a89794a2599344702R98 caused the wrong classloader to be used.
The user code classloader should be used directly, not its parent. That change seems to be irrelevant to the issue, and seems to have been changed by accident.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)