You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by di...@apache.org on 2022/06/30 14:55:37 UTC
[doris-flink-connector] branch master updated: FIX: fix wrap null (#41)
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 <st...@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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org