(inlong) branch master updated: [INLONG-9271][Manager] When creating 'StreamField', 'isMetaField' must be initialized (#9272)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang 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 f1ba3077d3 [INLONG-9271][Manager] When creating 'StreamField', 
'isMetaField' must be initialized (#9272)
f1ba3077d3 is described below

commit f1ba3077d35b5f0e0382e98f4217f1be23747a5e
Author: LiJie20190102 <53458004+lijie20190...@users.noreply.github.com>
AuthorDate: Tue Nov 14 09:38:17 2023 +0800

    [INLONG-9271][Manager] When creating 'StreamField', 'isMetaField' must be 
initialized (#9272)
    
    Co-authored-by: lijie0203 <li...@qishudi.com>
---
 .../org/apache/inlong/manager/pojo/stream/StreamField.java  |  2 ++
 .../inlong/manager/pojo/sort/util/FieldInfoUtilsTest.java   | 13 +++++++++++++
 2 files changed, 15 insertions(+)

diff --git 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/StreamField.java
 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/StreamField.java
index e7e0d9a60b..ca3bd2d394 100644
--- 
a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/StreamField.java
+++ 
b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/StreamField.java
@@ -101,6 +101,8 @@ public class StreamField implements Serializable {
         this.fieldName = fieldName;
         this.fieldComment = fieldComment;
         this.fieldValue = fieldValue;
+        // default
+        this.isMetaField = 0;
     }
 
     public StreamField(int index, String fieldType, String fieldName, String 
fieldComment, String fieldValue,
diff --git 
a/inlong-manager/manager-pojo/src/test/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtilsTest.java
 
b/inlong-manager/manager-pojo/src/test/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtilsTest.java
index 30dd2bb66d..f1394c9b73 100644
--- 
a/inlong-manager/manager-pojo/src/test/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtilsTest.java
+++ 
b/inlong-manager/manager-pojo/src/test/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtilsTest.java
@@ -17,6 +17,7 @@
 
 package org.apache.inlong.manager.pojo.sort.util;
 
+import org.apache.inlong.manager.common.enums.FieldType;
 import 
org.apache.inlong.manager.common.fieldtype.strategy.ClickHouseFieldTypeStrategy;
 import 
org.apache.inlong.manager.common.fieldtype.strategy.MongoDBFieldTypeStrategy;
 import 
org.apache.inlong.manager.common.fieldtype.strategy.MySQLFieldTypeStrategy;
@@ -40,6 +41,18 @@ import org.junit.jupiter.api.Test;
  */
 public class FieldInfoUtilsTest {
 
+    @Test
+    public void testCreateFieldTypeInfo() {
+
+        StreamField streamField = new StreamField(0, 
FieldType.STRING.toString(), "name", null, null);
+
+        FieldInfo fieldInfo = FieldInfoUtils.parseStreamFieldInfo(streamField,
+                "nodeId", new MySQLFieldTypeStrategy());
+
+        TypeInfo typeInfo = fieldInfo.getFormatInfo().getTypeInfo();
+        Assertions.assertTrue(typeInfo instanceof StringTypeInfo);
+    }
+
     @Test
     public void testPostgreSQLFieldTypeInfo() {
         StreamField streamField = new StreamField();