From 6a0bbf334481e35c8039d8e8b0f264b828ce5190 Mon Sep 17 00:00:00 2001
From: lanyuanxiaoyao <lanyuanxiaoyao@gmail.com>
Date: Mon, 4 Mar 2024 11:07:50 +0800
Subject: [PATCH] =?UTF-8?q?fix(sync):=20=E4=BF=AE=E5=A4=8Ddecimal=E5=AD=97?=
 =?UTF-8?q?=E6=AE=B5=E4=B8=BA=E7=A9=BA=E6=97=B6=E6=8A=9B=E5=87=BA=E5=BC=82?=
 =?UTF-8?q?=E5=B8=B8=20=E4=BD=BF=E7=94=A8=E8=BF=94=E5=9B=9Enull=E6=9B=BF?=
 =?UTF-8?q?=E4=BB=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/sync/functions/type/TypeConverterV2.java           | 3 +++
 1 file changed, 3 insertions(+)

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 bf1d4ad..deb58dc 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
@@ -133,6 +133,9 @@ public class TypeConverterV2 implements TypeConverter {
         } else {
             for (Schema type : schema.getTypes()) {
                 if (type.getLogicalType() instanceof LogicalTypes.Decimal) {
+                    if (StrUtil.isBlankIfStr(value)) {
+                        return null;
+                    }
                     LogicalTypes.Decimal decimalType = (LogicalTypes.Decimal) type.getLogicalType();
                     int precision = decimalType.getPrecision();
                     int scala = decimalType.getScale();