Skip to content

Commit b496437

Browse files
committed
[FLINK-34996][Connectors/Kafka] Use UserCodeClassLoader to instantiate Deserializer.
1 parent 369e7be commit b496437

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializerWrapper.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ public void open(DeserializationSchema.InitializationContext context) throws Exc
6565
InstantiationUtil.instantiate(
6666
deserializerClass.getName(),
6767
Deserializer.class,
68-
getClass().getClassLoader());
68+
userCodeClassLoader);
6969

7070
if (deserializer instanceof Configurable) {
7171
((Configurable) deserializer).configure(config);

0 commit comments

Comments
 (0)