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
+            );
         }
     }