This is an automated email from the ASF dual-hosted git repository.
fuweng11 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 9afbb8c427 [INLONG-12131][Manager] Fix the issue where jsonconfig
cannot be serialized correctly (#12132)
9afbb8c427 is described below
commit 9afbb8c4275d61c98add9297710e31a797ce4908
Author: fuweng11 <[email protected]>
AuthorDate: Thu May 28 16:28:06 2026 +0800
[INLONG-12131][Manager] Fix the issue where jsonconfig cannot be serialized
correctly (#12132)
Co-authored-by: wakefu <[email protected]>
---
.../java/org/apache/inlong/common/constant/DeserializationType.java | 2 ++
.../inlong/common/pojo/sort/dataflow/dataType/DataTypeConfig.java | 1 +
2 files changed, 3 insertions(+)
diff --git
a/inlong-common/src/main/java/org/apache/inlong/common/constant/DeserializationType.java
b/inlong-common/src/main/java/org/apache/inlong/common/constant/DeserializationType.java
index 0109f2f992..5b5d7b7111 100644
---
a/inlong-common/src/main/java/org/apache/inlong/common/constant/DeserializationType.java
+++
b/inlong-common/src/main/java/org/apache/inlong/common/constant/DeserializationType.java
@@ -25,4 +25,6 @@ public class DeserializationType {
public static final String CSV = "csv";
public static final String KV = "kv";
public static final String PB = "pb";
+ public static final String JSON = "json";
+
}
diff --git
a/inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/dataflow/dataType/DataTypeConfig.java
b/inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/dataflow/dataType/DataTypeConfig.java
index c81c6a5919..bf7d49d3e3 100644
---
a/inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/dataflow/dataType/DataTypeConfig.java
+++
b/inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/dataflow/dataType/DataTypeConfig.java
@@ -29,6 +29,7 @@ import java.io.Serializable;
@JsonSubTypes.Type(value = CsvConfig.class, name =
DeserializationType.CSV),
@JsonSubTypes.Type(value = KvConfig.class, name =
DeserializationType.KV),
@JsonSubTypes.Type(value = PbConfig.class, name =
DeserializationType.PB),
+ @JsonSubTypes.Type(value = JsonConfig.class, name =
DeserializationType.JSON),
})
public interface DataTypeConfig extends Serializable {