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)