From 55809f25f0d7d4a0b62763a6ffee6e0ff4bcda56 Mon Sep 17 00:00:00 2001 From: StrikeW Date: Thu, 13 Jun 2024 17:43:04 +0800 Subject: [PATCH] minor --- .../src/main/java/com/risingwave/connector/JdbcUtils.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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));