fix: classloader issue for SerializedThrowableDeserializer

jrthe42 · Feb 22, 2024 · 26bbaef · 26bbaef
1 parent e7e973e
commit 26bbaef
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ain/java/org/apache/flink/runtime/rest/messages/json/SerializedThrowableDeserializer.java b/...ain/java/org/apache/flink/runtime/rest/messages/json/SerializedThrowableDeserializer.java
@@ -47,7 +47,7 @@ public SerializedThrowable deserialize(final JsonParser p, final Deserialization
         final byte[] serializedException = root.get(FIELD_NAME_SERIALIZED_THROWABLE).binaryValue();
         try {
             return InstantiationUtil.deserializeObject(
-                    serializedException, ClassLoader.getSystemClassLoader());
+                    serializedException, Thread.currentThread().getContextClassLoader());
         } catch (ClassNotFoundException e) {
             throw new IOException(
                     "Failed to deserialize " + SerializedThrowable.class.getCanonicalName(), e);