fix(sync): 修复错误信息没有吐出到控制台

This commit is contained in:
v-zhangjc9
2024-03-26 14:50:18 +08:00
parent 15fd6d30c2
commit 11e2998a52

View File

@@ -111,8 +111,10 @@ public class TypeConverterV2 implements TypeConverter {
return NULLABLE_STRING_SCHEMA; return NULLABLE_STRING_SCHEMA;
} }
} catch (Throwable throwable) { } catch (Throwable throwable) {
logger.error(StrUtil.format("Convert type failure {} {} {} length: {} scala: {}", table, field, type, length, scala), throwable); throw new RuntimeException(
throw throwable; StrUtil.format("Convert type failure {} {} {} length: {} scala: {}", table, field, type, length, scala),
throwable
);
} }
} }
@@ -174,8 +176,10 @@ public class TypeConverterV2 implements TypeConverter {
return value; return value;
} }
} catch (Throwable throwable) { } catch (Throwable throwable) {
logger.error(StrUtil.format("Convert value failure {} {} {}", schema.toString(), name, value), throwable); throw new RuntimeException(
throw throwable; StrUtil.format("Convert value failure {} {} {}", schema.toString(), name, value),
throwable
);
} }
} }