diff --git a/java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JdbcUtils.java b/java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JdbcUtils.java index bf6167667a494..52f6fe076c175 100644 --- a/java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JdbcUtils.java +++ b/java/connector-node/risingwave-sink-jdbc/src/main/java/com/risingwave/connector/JdbcUtils.java @@ -51,7 +51,7 @@ public static Connection getConnection(String jdbcUrl) throws SQLException { // postgres use seconds and mysql use milliseconds int connectTimeout = isPg ? CONNECTION_TIMEOUT : CONNECTION_TIMEOUT * 1000; - int socketTimeout = isPg ? SOCKET_TIMEOUT: SOCKET_TIMEOUT * 1000; + int socketTimeout = isPg ? SOCKET_TIMEOUT : SOCKET_TIMEOUT * 1000; props.setProperty("connectTimeout", String.valueOf(connectTimeout)); props.setProperty("socketTimeout", String.valueOf(socketTimeout));