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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
