(paimon) branch master updated: [flink-cdc] Stabilize schema change IT under load (#8585)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 5cfb2cf659 [flink-cdc] Stabilize schema change IT under load (#8585)
5cfb2cf659 is described below

commit 5cfb2cf65920478376ca472a512c527ebf631eec
Author: Arnav Balyan <60175178+arnavbal...@users.noreply.github.com>
AuthorDate: Mon Jul 13 09:01:49 2026 +0530

    [flink-cdc] Stabilize schema change IT under load (#8585)
---
 .../paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionITCase.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionITCase.java
 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionITCase.java
index 976f391b95..042b4ddbcf 100644
--- 
a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionITCase.java
+++ 
b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionITCase.java
@@ -801,6 +801,11 @@ public class MySqlSyncDatabaseActionITCase extends 
MySqlActionITCaseBase {
             tableName = getNewTableName(pick);
             records = recordsMap.get(tableName);
 
+            // Wait for the newly added table to finish its incremental 
snapshot before altering it.
+            // Under load a snapshot split can capture the post-ALTER schema 
and the binlog split
+            // then replays pre-ALTER rows against it (row smaller than column 
index error).
+            Thread.sleep(10000);
+
             statement.executeUpdate(
                     String.format(
                             "ALTER TABLE `%s`.`%s` ADD COLUMN v2 INT", 
databaseName, tableName));