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 f0fc863df5 [Improve][Connector-V2][Jdbc] Increase timeout for schema
change IT to fix flaky test (#10258)
f0fc863df5 is described below
commit f0fc863df5a1c59bbcc172da67053fb5d159bb31
Author: Jast <[email protected]>
AuthorDate: Sun Jan 4 15:37:41 2026 +0800
[Improve][Connector-V2][Jdbc] Increase timeout for schema change IT to fix
flaky test (#10258)
---
.../jdbc/AbstractSchemaChangeBaseIT.java | 30 +++++++++++-----------
1 file changed, 15 insertions(+), 15 deletions(-)
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/java/org/apache/seatunnel/connectors/jdbc/AbstractSchemaChangeBaseIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/java/org/apache/seatunnel/connectors/jdbc/AbstractSchemaChangeBaseIT.java
index a467428f51..01bcf2db2f 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/java/org/apache/seatunnel/connectors/jdbc/AbstractSchemaChangeBaseIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-ddl/src/test/java/org/apache/seatunnel/connectors/jdbc/AbstractSchemaChangeBaseIT.java
@@ -79,7 +79,7 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
private static final String MYSQL_USER_NAME = "mysqluser";
private static final String MYSQL_USER_PASSWORD = "mysqlpw";
- private static final String OPRDER_BY = " order by id";
+ private static final String ORDER_BY = " order by id";
private static final String QUERY = "select * from %s.%s";
private static final String PROJECTION_QUERY =
"select
id,name,description,weight,add_column1,add_column2,add_column3 from %s.%s";
@@ -292,7 +292,7 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
}
private void assertSchemaEvolution(String sourceTable, String sinkTable) {
- await().atMost(30000, TimeUnit.MILLISECONDS)
+ await().atMost(60000, TimeUnit.MILLISECONDS)
.untilAsserted(
() ->
Assertions.assertIterableEquals(
@@ -303,11 +303,11 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
QUERY,
schemaChangeCase.getSchemaName(),
sinkTable)
- + OPRDER_BY)));
+ + ORDER_BY)));
// case1 add columns with cdc data at same time
sourceDatabase.setTemplateName("add_columns").createAndInitialize();
- await().atMost(30000, TimeUnit.MILLISECONDS)
+ await().atMost(60000, TimeUnit.MILLISECONDS)
.untilAsserted(
() ->
Assertions.assertIterableEquals(
@@ -321,7 +321,7 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
schemaChangeCase.getSinkQueryColumns(),
schemaChangeCase.getSchemaName(),
sinkTable))));
- await().atMost(30000, TimeUnit.MILLISECONDS)
+ await().atMost(60000, TimeUnit.MILLISECONDS)
.untilAsserted(
() -> {
Assertions.assertIterableEquals(
@@ -334,7 +334,7 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
schemaChangeCase.getSchemaName(),
sinkTable)
+ " where id >= 128"
- + OPRDER_BY));
+ + ORDER_BY));
Assertions.assertIterableEquals(
querySource(
@@ -347,7 +347,7 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
PROJECTION_QUERY,
schemaChangeCase.getSchemaName(),
sinkTable)
- + OPRDER_BY));
+ + ORDER_BY));
});
// case2 drop columns with cdc data at same time
@@ -366,7 +366,7 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
}
private void assertSchemaEvolutionForAddColumns(String sourceTable, String
sinkTable) {
- await().atMost(30000, TimeUnit.MILLISECONDS)
+ await().atMost(60000, TimeUnit.MILLISECONDS)
.untilAsserted(
() ->
Assertions.assertIterableEquals(
@@ -377,13 +377,13 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
QUERY,
schemaChangeCase.getSchemaName(),
sinkTable)
- + OPRDER_BY)));
+ + ORDER_BY)));
// case1 add columns with cdc data at same time
sourceDatabase.setTemplateName("add_columns").createAndInitialize();
given().pollDelay(Duration.ofSeconds(5))
.await()
- .atMost(60000, TimeUnit.MILLISECONDS)
+ .atMost(120000, TimeUnit.MILLISECONDS)
.untilAsserted(
() ->
Assertions.assertIterableEquals(
@@ -394,8 +394,8 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
QUERY,
schemaChangeCase.getSchemaName(),
sinkTable)
- + OPRDER_BY)));
- await().atMost(30000, TimeUnit.MILLISECONDS)
+ + ORDER_BY)));
+ await().atMost(60000, TimeUnit.MILLISECONDS)
.untilAsserted(
() -> {
Assertions.assertIterableEquals(
@@ -408,7 +408,7 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
schemaChangeCase.getSchemaName(),
sinkTable)
+ " where id >= 128"
- + OPRDER_BY));
+ + ORDER_BY));
Assertions.assertIterableEquals(
querySource(
@@ -421,7 +421,7 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
PROJECTION_QUERY,
schemaChangeCase.getSchemaName(),
sinkTable)
- + OPRDER_BY));
+ + ORDER_BY));
});
}
@@ -453,7 +453,7 @@ public abstract class AbstractSchemaChangeBaseIT extends
TestSuiteBase implement
QUERY,
schemaChangeCase.getSchemaName(),
sinkTable)
- + OPRDER_BY)));
+ + ORDER_BY)));
}
private Connection getJdbcConnection(String connectionType) throws
SQLException {
