diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/JsonSerdeUtil.java b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/JsonSerdeUtil.java
index ced64c8bf86e6..34bd234e6d941 100644
--- a/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/JsonSerdeUtil.java
+++ b/flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/JsonSerdeUtil.java
@@ -53,6 +53,8 @@ public static ObjectMapper createObjectMapper(SerdeContext serdeCtx) {
                         null, // JsonFactory
                         null, // DefaultSerializerProvider
                         ctx);
+        mapper.setTypeFactory(
+                mapper.getTypeFactory().withClassLoader(JsonSerdeUtil.class.getClassLoader()));
         mapper.configure(MapperFeature.USE_GETTERS_AS_SETTERS, false);
         ctx.setObjectMapper(mapper);
         return mapper;