diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/converter/ValueConverter.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/converter/ValueConverter.java
index db38102ca9d5..09e2f265ec55 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/converter/ValueConverter.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/transform/converter/ValueConverter.java
@@ -527,11 +527,11 @@ public static boolean convertTextToBoolean(final Binary value) {
   }
 
   public static int convertTextToInt32(final Binary value) {
-    return parseInteger(value.toString());
+    return (int) parseDouble(value.toString());
   }
 
   public static long convertTextToInt64(final Binary value) {
-    return parseLong(value.toString());
+    return (long) parseDouble(value.toString());
   }
 
   public static float convertTextToFloat(final Binary value) {
@@ -653,11 +653,11 @@ public static boolean convertBlobToBoolean(final Binary value) {
   }
 
   public static int convertBlobToInt32(final Binary value) {
-    return parseInteger(value.toString());
+    return (int) parseDouble(value.toString());
   }
 
   public static long convertBlobToInt64(final Binary value) {
-    return parseLong(value.toString());
+    return (long) parseDouble(value.toString());
   }
 
   public static float convertBlobToFloat(final Binary value) {
@@ -691,11 +691,11 @@ public static boolean convertStringToBoolean(final Binary value) {
   }
 
   public static int convertStringToInt32(final Binary value) {
-    return parseInteger(value.toString());
+    return (int) parseDouble(value.toString());
   }
 
   public static long convertStringToInt64(final Binary value) {
-    return parseLong(value.toString());
+    return (long) parseDouble(value.toString());
   }
 
   public static float convertStringToFloat(final Binary value) {