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");
                                 }

Reply via email to