diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java index 7004309d2d..a58ac1a350 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java @@ -400,7 +400,8 @@ public class JdbcMySQLClient extends JdbcClient { return ScalarType.createDateV2Type(); case "DATETIME": case "DATETIMEV2": { - int scale = Integer.parseInt(upperType.substring(openParen + 1, upperType.length() - 1)); + int scale = (openParen == -1) ? 6 + : Integer.parseInt(upperType.substring(openParen + 1, upperType.length() - 1)); if (scale > 6) { scale = 6; }