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();