[doris-flink-connector] branch master updated: FIX: fix wrap null (#41)

[diwu]

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

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new ab3bf15  FIX: fix wrap null (#41)
ab3bf15 is described below

commit ab3bf15c9e768887ad461d384eadd9a9784f4f8f
Author: Stalary <stal...@163.com>
AuthorDate: Thu Jun 30 22:55:33 2022 +0800

    FIX: fix wrap null (#41)
---
 .../apache/doris/flink/deserialization/converter/DorisRowConverter.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java
 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java
index d1bb529..79c3b81 100644
--- 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java
+++ 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java
@@ -115,7 +115,7 @@ public class DorisRowConverter implements Serializable {
 
     protected SerializationConverter 
wrapIntoNullableExternalConverter(SerializationConverter 
serializationConverter) {
         return (index, val) -> {
-            if (val == null) {
+            if (val == null || val.isNullAt(index)) {
                 return null;
             } else {
                 return serializationConverter.serialize(index, val);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org