[inlong] branch master updated: [INLONG-7252][Sort] Fix Doris connector throw NPE when DATE type data is null (#7259)

[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 8d83159db [INLONG-7252][Sort] Fix Doris connector throw NPE when DATE 
type data is null (#7259)
8d83159db is described below

commit 8d83159dbab9588c9d7d7618b6c814fecef5b952
Author: Xin Gong <genzhedangd...@gmail.com>
AuthorDate: Tue Jan 17 21:34:08 2023 +0800

    [INLONG-7252][Sort] Fix Doris connector throw NPE when DATE type data is 
null (#7259)
---
 .../inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java    | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
 
b/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
index efa04a630..91f3c67b3 100644
--- 
a/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
+++ 
b/inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java
@@ -254,7 +254,12 @@ public class DorisDynamicSchemaOutputFormat<T> extends 
RichOutputFormat<T> {
                 fieldGetters[i] = RowData.createFieldGetter(logicalTypes[i], 
i);
                 if ("DATE".equalsIgnoreCase(logicalTypes[i].toString())) {
                     int finalI = i;
-                    fieldGetters[i] = row -> 
DorisParseUtils.epochToDate(row.getInt(finalI));
+                    fieldGetters[i] = row -> {
+                        if (row.isNullAt(finalI)) {
+                            return null;
+                        }
+                        return DorisParseUtils.epochToDate(row.getInt(finalI));
+                    };
                 }
             }
         }