From 5bad6b6e1e988af4e736e309172c51f35643c662 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Thu, 13 Jun 2024 16:26:44 +0800 Subject: [PATCH] =?UTF-8?q?fix(sync):=20=E4=BC=98=E5=8C=96TypeConverterV2?= =?UTF-8?q?=E7=9A=84=E7=A9=BA=E5=80=BC=E5=88=A4=E6=96=AD=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/sync/functions/type/TypeConverterV2.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/type/TypeConverterV2.java b/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/type/TypeConverterV2.java index c8e26c6..8ece80b 100644 --- a/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/type/TypeConverterV2.java +++ b/utils/sync/src/main/java/com/lanyuanxiaoyao/service/sync/functions/type/TypeConverterV2.java @@ -20,7 +20,11 @@ import org.apache.hudi.org.apache.avro.Schema; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import static org.apache.hudi.org.apache.avro.Schema.*; +import static org.apache.hudi.org.apache.avro.Schema.Field; +import static org.apache.hudi.org.apache.avro.Schema.Type; +import static org.apache.hudi.org.apache.avro.Schema.create; +import static org.apache.hudi.org.apache.avro.Schema.createFixed; +import static org.apache.hudi.org.apache.avro.Schema.createUnion; /** * 类型转换第二版本 @@ -184,6 +188,6 @@ public class TypeConverterV2 implements TypeConverter { } private boolean isNullValue(Object value) { - return StrUtil.isBlankIfStr(value) || ObjectUtil.equals("null", value); + return StrUtil.isBlankIfStr(value) || (value instanceof String ? "null".equalsIgnoreCase((String) value) : value == null); } }