This is an automated email from the ASF dual-hosted git repository.
davidzollo 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 ec577362ec [Test][E2E] Stabilize Db2 upsert timestamp comparison
(#11150)
ec577362ec is described below
commit ec577362ecb902bb3501a374106993fec7b55333
Author: Daniel <[email protected]>
AuthorDate: Thu Jul 2 23:09:03 2026 +0800
[Test][E2E] Stabilize Db2 upsert timestamp comparison (#11150)
---
.../apache/seatunnel/connectors/seatunnel/jdbc/JdbcDb2UpsertIT.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDb2UpsertIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDb2UpsertIT.java
index e1304dd4d5..8de745e120 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDb2UpsertIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDb2UpsertIT.java
@@ -94,7 +94,9 @@ public class JdbcDb2UpsertIT extends JdbcDb2IT {
List<List<Object>> updatedAtTimestampsBeforeUpdate =
query(
String.format(
- "SELECT C_UPDATED_AT FROM %s",
+ // Keep row order stable so repeated reads
compare the same
+ // records.
+ "SELECT C_UPDATED_AT FROM %s ORDER BY
C_INT",
buildTableInfoWithSchema(DB2_DATABASE,
DB2_SINK)));
// step 2: run the job to update the data in the sink.
// expected: timestamps should not be updated as the data is not
changed.
@@ -103,7 +105,7 @@ public class JdbcDb2UpsertIT extends JdbcDb2IT {
List<List<Object>> updatedAtTimestampsAfterUpdate =
query(
String.format(
- "SELECT C_UPDATED_AT FROM %s",
+ "SELECT C_UPDATED_AT FROM %s ORDER BY
C_INT",
buildTableInfoWithSchema(DB2_DATABASE,
DB2_SINK)));
Assertions.assertIterableEquals(
updatedAtTimestampsBeforeUpdate,
updatedAtTimestampsAfterUpdate);
