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 {
 

Reply via email to