(seatunnel) branch dev updated: [Fix][E2E] Stabilize Paimon incompatible schema test (#11608)

[shenghang]

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

zhangshenghang 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 39d4f81ef9 [Fix][E2E] Stabilize Paimon incompatible schema test 
(#11608)
39d4f81ef9 is described below

commit 39d4f81ef979d1d1b4f4493d2ebe48ec5a0a1b5b
Author: David Zollo <davidzollo...@gmail.com>
AuthorDate: Sun Aug 23 22:09:40 2026 +0800

    [Fix][E2E] Stabilize Paimon incompatible schema test (#11608)
---
 .../org/apache/seatunnel/e2e/connector/paimon/PaimonSinkCDCIT.java | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paimon-e2e/src/test/java/org/apache/seatunnel/e2e/connector/paimon/PaimonSinkCDCIT.java
 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paimon-e2e/src/test/java/org/apache/seatunnel/e2e/connector/paimon/PaimonSinkCDCIT.java
index a8dc33252a..a558c098e5 100644
--- 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paimon-e2e/src/test/java/org/apache/seatunnel/e2e/connector/paimon/PaimonSinkCDCIT.java
+++ 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-paimon-e2e/src/test/java/org/apache/seatunnel/e2e/connector/paimon/PaimonSinkCDCIT.java
@@ -65,6 +65,10 @@ import static org.awaitility.Awaitility.given;
 @Slf4j
 public class PaimonSinkCDCIT extends AbstractPaimonIT implements TestResource {
 
+    /** Config used to verify the schema mismatch error after the target 
Paimon table exists. */
+    private static final String ERROR_SCHEMA_CONF =
+            "/fake_cdc_sink_paimon_case1_with_error_schema.conf";
+
     @BeforeEach
     @Override
     public void startUp() throws Exception {
@@ -138,8 +142,7 @@ public class PaimonSinkCDCIT extends AbstractPaimonIT 
implements TestResource {
     public void testSinkWithIncompatibleSchema(TestContainer container) throws 
Exception {
         Container.ExecResult execResult = 
container.executeJob("/fake_cdc_sink_paimon_case1.conf");
         Assertions.assertEquals(0, execResult.getExitCode());
-        Container.ExecResult errResult =
-                
container.executeJob("/fake_cdc_sink_paimon_case1_with_error_schema.conf");
+        Container.ExecResult errResult = 
container.executeJob(ERROR_SCHEMA_CONF);
         Assertions.assertEquals(1, errResult.getExitCode());
         Assertions.assertTrue(
                 errResult