(flink-connector-opensearch) branch main updated: [hotfix][opensearch] Make sure the dynamic sink tests pass across 2.1/2.2/2.3/2.4 Flink versions

[snuyanzin]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new f8038fc  [hotfix][opensearch] Make sure the dynamic sink tests pass 
across 2.1/2.2/2.3/2.4 Flink versions
f8038fc is described below

commit f8038fc74703259d1aa277f2347ce013547f93cc
Author: Andriy Redko <drr...@gmail.com>
AuthorDate: Mon Sep 21 18:01:24 2026 -0400

    [hotfix][opensearch] Make sure the dynamic sink tests pass across 
2.1/2.2/2.3/2.4 Flink versions
    
    Signed-off-by: Andriy Redko <drr...@gmail.com>
---
 .../flink/connector/opensearch/table/OpensearchDynamicSinkITCase.java | 4 ++--
 .../connector/opensearch/table/Opensearch2DynamicSinkITCase.java      | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkITCase.java
 
b/flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkITCase.java
index d638549..d90f597 100644
--- 
a/flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkITCase.java
+++ 
b/flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkITCase.java
@@ -130,7 +130,7 @@ class OpensearchDynamicSinkITCase {
         GenericRowData rowData =
                 GenericRowData.of(
                         1L,
-                        12345,
+                        12000,
                         StringData.fromString("ABCDE"),
                         12.12f,
                         (byte) 2,
@@ -163,7 +163,7 @@ class OpensearchDynamicSinkITCase {
                         .getSource();
         Map<Object, Object> expectedMap = new HashMap<>();
         expectedMap.put("a", 1);
-        expectedMap.put("b", "00:00:12.345");
+        expectedMap.put("b", "00:00:12");
         expectedMap.put("c", "ABCDE");
         expectedMap.put("d", 12.12d);
         expectedMap.put("e", 2);
diff --git 
a/flink-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch/table/Opensearch2DynamicSinkITCase.java
 
b/flink-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch/table/Opensearch2DynamicSinkITCase.java
index 7cbf0b5..74bc7b5 100644
--- 
a/flink-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch/table/Opensearch2DynamicSinkITCase.java
+++ 
b/flink-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch/table/Opensearch2DynamicSinkITCase.java
@@ -130,7 +130,7 @@ class Opensearch2DynamicSinkITCase {
         GenericRowData rowData =
                 GenericRowData.of(
                         1L,
-                        12345,
+                        12000,
                         StringData.fromString("ABCDE"),
                         12.12f,
                         (byte) 2,
@@ -163,7 +163,7 @@ class Opensearch2DynamicSinkITCase {
                         .getSource();
         Map<Object, Object> expectedMap = new HashMap<>();
         expectedMap.put("a", 1);
-        expectedMap.put("b", "00:00:12.345");
+        expectedMap.put("b", "00:00:12");
         expectedMap.put("c", "ABCDE");
         expectedMap.put("d", 12.12d);
         expectedMap.put("e", 2);