[incubator-inlong] branch master updated: [INLONG-3064][Manager] Unify field types of sink and source in manager client (#3468)

[he...@apache.org]

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

healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 2cf348b  [INLONG-3064][Manager] Unify field types of sink and source in manager client (#3468)
2cf348b is described below

commit 2cf348baa0656e2f85ff665a05558a9a37e77763
Author: yunqingmoswu <44...@users.noreply.github.com>
AuthorDate: Wed Mar 30 16:36:23 2022 +0800

    [INLONG-3064][Manager] Unify field types of sink and source in manager client (#3468)
---
 .../src/main/java/org/apache/inlong/manager/client/api/SinkField.java | 4 ++--
 .../inlong/manager/client/api/util/InlongStreamSinkTransfer.java      | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/SinkField.java b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/SinkField.java
index 09f2ef9..9ed71b3 100644
--- a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/SinkField.java
+++ b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/SinkField.java
@@ -34,10 +34,10 @@ public class SinkField extends StreamField {
     private String sourceFieldName;
 
     @ApiModelProperty("Source field type")
-    private String sourceFieldType;
+    private FieldType sourceFieldType;
 
     public SinkField(int index, FieldType fieldType, String fieldName, String fieldComment,
-            String fieldValue, String sourceFieldName, String sourceFieldType,
+            String fieldValue, String sourceFieldName, FieldType sourceFieldType,
             Integer isMetaField, String fieldFormat) {
         super(index, fieldType, fieldName, fieldComment, fieldValue, isMetaField, fieldFormat);
         this.sourceFieldName = sourceFieldName;
diff --git a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamSinkTransfer.java b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamSinkTransfer.java
index fb68071..2e68eea 100644
--- a/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamSinkTransfer.java
+++ b/inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongStreamSinkTransfer.java
@@ -152,7 +152,7 @@ public class InlongStreamSinkTransfer {
                 sinkFieldResponse.getFieldName(),
                 sinkFieldResponse.getFieldComment(),
                 null, sinkFieldResponse.getSourceFieldName(),
-                sinkFieldResponse.getSourceFieldType(),
+                FieldType.forName(sinkFieldResponse.getSourceFieldType()),
                 sinkFieldResponse.getIsMetaField(),
                 sinkFieldResponse.getFieldFormat())).collect(Collectors.toList());
 
@@ -238,7 +238,7 @@ public class InlongStreamSinkTransfer {
             request.setFieldType(sinkField.getFieldType().toString());
             request.setFieldComment(sinkField.getFieldComment());
             request.setSourceFieldName(sinkField.getSourceFieldName());
-            request.setSourceFieldType(sinkField.getSourceFieldType());
+            request.setSourceFieldType(sinkField.getSourceFieldType().toString());
             request.setIsMetaField(sinkField.getIsMetaField());
             request.setFieldFormat(sinkField.getFieldFormat());
             fieldRequestList.add(request);