From 11e2998a52f86fa6fbc2a48f5622d250ba97f2e6 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Tue, 26 Mar 2024 14:50:18 +0800 Subject: [PATCH] =?UTF-8?q?fix(sync):=20=E4=BF=AE=E5=A4=8D=E9=94=99?= =?UTF-8?q?=E8=AF=AF=E4=BF=A1=E6=81=AF=E6=B2=A1=E6=9C=89=E5=90=90=E5=87=BA?= =?UTF-8?q?=E5=88=B0=E6=8E=A7=E5=88=B6=E5=8F=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/sync/functions/type/TypeConverterV2.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 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 33197e4..c8e26c6 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 @@ -111,8 +111,10 @@ public class TypeConverterV2 implements TypeConverter { return NULLABLE_STRING_SCHEMA; } } catch (Throwable throwable) { - logger.error(StrUtil.format("Convert type failure {} {} {} length: {} scala: {}", table, field, type, length, scala), throwable); - throw throwable; + throw new RuntimeException( + StrUtil.format("Convert type failure {} {} {} length: {} scala: {}", table, field, type, length, scala), + throwable + ); } } @@ -174,8 +176,10 @@ public class TypeConverterV2 implements TypeConverter { return value; } } catch (Throwable throwable) { - logger.error(StrUtil.format("Convert value failure {} {} {}", schema.toString(), name, value), throwable); - throw throwable; + throw new RuntimeException( + StrUtil.format("Convert value failure {} {} {}", schema.toString(), name, value), + throwable + ); } }