(flink-connector-mongodb) branch main updated: [hotfix] Fix test-case failure for Flink 2.2 support

[fcsaky]

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

fcsaky pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-mongodb.git


The following commit(s) were added to refs/heads/main by this push:
     new 414058a  [hotfix] Fix test-case failure for Flink 2.2 support
414058a is described below

commit 414058a7eb1fc8bf5a043807e33a1ffab289ee41
Author: Rahul Teke <neoneo...@users.noreply.github.com>
AuthorDate: Wed Mar 4 19:07:20 2026 +0000

    [hotfix] Fix test-case failure for Flink 2.2 support
---
 .github/workflows/push_pr.yml                                     | 4 ++--
 .../connector/mongodb/table/MongoPartitionedTableSinkITCase.java  | 8 +++++++-
 2 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/.github/workflows/push_pr.yml b/.github/workflows/push_pr.yml
index a8d750d..9215917 100644
--- a/.github/workflows/push_pr.yml
+++ b/.github/workflows/push_pr.yml
@@ -29,8 +29,8 @@ jobs:
     strategy:
       matrix:
         mongodb: [ mongodb4, mongodb5, mongodb6, mongodb7 ]
-        flink: [ 2.1-SNAPSHOT ]
-        jdk: [ '11','17, 21' ]
+        flink: [ 2.1-SNAPSHOT, 2.2-SNAPSHOT ]
+        jdk: [ '11','17', '21' ]
 
     uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
     with:
diff --git 
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPartitionedTableSinkITCase.java
 
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPartitionedTableSinkITCase.java
index 69e4ba2..712a6fe 100644
--- 
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPartitionedTableSinkITCase.java
+++ 
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPartitionedTableSinkITCase.java
@@ -136,8 +136,14 @@ class MongoPartitionedTableSinkITCase {
         createPartitionedTable(tEnv, database, collection, primaryKeys, 
Arrays.asList("b", "c"));
 
         // update the shard key value should be failed.
+
+        // The exception during close were moved from job execution result in 
below flink commit.
+        // The suppressedException field contained the original failure
+        // As such there is no way to determine the root cause of failure
+        // Checking for generic failure until fink is fixed for it.
+        // 
https://github.com/apache/flink/pull/26861/changes#diff-b84174e55cb1999d99ad60cdeded7be20ff4978472bfc785c5a77b6270f47b56L947
         assertThatThrownBy(() -> 
tEnv.fromValues(testValues).executeInsert("mongo_sink").await())
-                .hasStackTraceContaining("Writing records to MongoDB failed");
+                .hasStackTraceContaining("Job execution failed");
     }
 
     @Test