[incubator-inlong] branch master updated: [INLONG-3480][Manager] Fix null pointer exception when calling sink method in manager client (#3485)

[healchow]

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 8a59cdb  [INLONG-3480][Manager] Fix null pointer exception when 
calling sink method in manager client (#3485)
8a59cdb is described below

commit 8a59cdb63dba2b9785afb3f90a950131be93b0cf
Author: yunqingmoswu <44659300+yunqingmo...@users.noreply.github.com>
AuthorDate: Thu Mar 31 09:53:07 2022 +0800

    [INLONG-3480][Manager] Fix null pointer exception when calling sink method 
in manager client (#3485)
---
 .../inlong/manager/client/api/util/InlongStreamSinkTransfer.java   | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

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 2e68eea..751469d 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
@@ -19,6 +19,7 @@ package org.apache.inlong.manager.client.api.util;
 
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.compress.utils.Lists;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.inlong.manager.client.api.DataFormat;
 import org.apache.inlong.manager.client.api.DataSeparator;
 import org.apache.inlong.manager.client.api.SinkField;
@@ -152,7 +153,8 @@ public class InlongStreamSinkTransfer {
                 sinkFieldResponse.getFieldName(),
                 sinkFieldResponse.getFieldComment(),
                 null, sinkFieldResponse.getSourceFieldName(),
-                FieldType.forName(sinkFieldResponse.getSourceFieldType()),
+                StringUtils.isBlank(sinkFieldResponse.getSourceFieldType()) ? 
null :
+                        
FieldType.forName(sinkFieldResponse.getSourceFieldType()),
                 sinkFieldResponse.getIsMetaField(),
                 
sinkFieldResponse.getFieldFormat())).collect(Collectors.toList());
 
@@ -238,7 +240,8 @@ public class InlongStreamSinkTransfer {
             request.setFieldType(sinkField.getFieldType().toString());
             request.setFieldComment(sinkField.getFieldComment());
             request.setSourceFieldName(sinkField.getSourceFieldName());
-            
request.setSourceFieldType(sinkField.getSourceFieldType().toString());
+            request.setSourceFieldType(
+                    sinkField.getSourceFieldType() == null ? null : 
sinkField.getSourceFieldType().toString());
             request.setIsMetaField(sinkField.getIsMetaField());
             request.setFieldFormat(sinkField.getFieldFormat());
             fieldRequestList.add(request);