This is an automated email from the ASF dual-hosted git repository.
corgy pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new fd3c295328 [Imporve][Connector-v2][MySQL-CDC]Schema evolution
optimization waiting time (#10040)
fd3c295328 is described below
commit fd3c2953286a8984d4a8a8ef6c91ac9f2e2d16e3
Author: Jast <[email protected]>
AuthorDate: Sat Nov 8 21:31:39 2025 +0800
[Imporve][Connector-v2][MySQL-CDC]Schema evolution optimization waiting
time (#10040)
---
.../seatunnel/cdc/mysql/MysqlCDCWithFlinkSchemaChangeIT.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/MysqlCDCWithFlinkSchemaChangeIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/MysqlCDCWithFlinkSchemaChangeIT.java
index 7b960bf13c..4f4fbe8db9 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/MysqlCDCWithFlinkSchemaChangeIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/MysqlCDCWithFlinkSchemaChangeIT.java
@@ -197,8 +197,8 @@ public class MysqlCDCWithFlinkSchemaChangeIT extends
TestSuiteBase implements Te
while (resultSet.next()) {
int timeDiff =
resultSet.getInt("time_diff");
Assertions.assertTrue(
- timeDiff <= 3,
- "Time difference exceeds 3
seconds: "
+ timeDiff <= 6,
+ "Time difference exceeds 6
seconds: "
+ timeDiff
+ " seconds");
}