This is an automated email from the ASF dual-hosted git repository. leonardBang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit 03c499a8486185ef9b50883d86ae04905b1068a3 Author: Leonard Xu <[email protected]> AuthorDate: Wed Jul 1 14:57:45 2026 +0800 [test][connector/tidb] Retry TiDB JDBC startup connections --- .../apache/flink/cdc/connectors/tidb/TiDBTestBase.java | 18 +++++++++++++++++- 1 file changed, 17 insertions(+), 1 deletion(-) diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/TiDBTestBase.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/TiDBTestBase.java index 525fd2a28..f1b49e609 100644 --- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/TiDBTestBase.java +++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/test/java/org/apache/flink/cdc/connectors/tidb/TiDBTestBase.java @@ -151,7 +151,23 @@ public class TiDBTestBase extends AbstractTestBase { } protected Connection getJdbcConnection(String databaseName) throws SQLException { - return DriverManager.getConnection(getJdbcUrl(databaseName), TIDB_USER, TIDB_PASSWORD); + long deadline = System.nanoTime() + Duration.ofSeconds(120).toNanos(); + SQLException lastException = null; + while (System.nanoTime() < deadline) { + try { + return DriverManager.getConnection( + getJdbcUrl(databaseName), TIDB_USER, TIDB_PASSWORD); + } catch (SQLException e) { + lastException = e; + try { + Thread.sleep(1000L); + } catch (InterruptedException interruptedException) { + Thread.currentThread().interrupt(); + throw new SQLException(interruptedException); + } + } + } + throw lastException; } private static void dropTestDatabase(Connection connection, String databaseName)
