[hotfix] Update to support Flink 1.20.0

Signed-off-by: Andriy Redko <[email protected]>

Author: reta

.github/workflows/weekly.yml

@@ -37,7 +37,12 @@ jobs:
           jdk: '8, 11, 17, 21',
           branch: main
         }, {
-          flink: 1.20-SNAPSHOT,
+            flink: 1.20-SNAPSHOT,
+            jdk: '8, 11, 17, 21',
+            branch: main
+          }, 
+        {
+          flink: 1.20,
           jdk: '8, 11, 17, 21',
           branch: main
         }, {

flink-connector-opensearch-base/archunit-violations/5c4a6228-f9cb-4828-9625-43c57d133967

@@ -1,3 +1 @@
-Constructor <org.apache.flink.connector.opensearch.sink.BulkProcessorConfig.<init>(int, int, long, org.apache.flink.connector.opensearch.sink.FlushBackoffType, int, long)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (BulkProcessorConfig.java:44)
-Constructor <org.apache.flink.connector.opensearch.table.OpensearchConfiguration.<init>(org.apache.flink.configuration.ReadableConfig)> calls method <org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in (OpensearchConfiguration.java:61)
 Method <org.apache.flink.connector.opensearch.table.IndexGeneratorFactory.createRuntimeIndexGenerator(java.lang.String, [Ljava.lang.String;, [Lorg.apache.flink.table.types.DataType;, org.apache.flink.connector.opensearch.table.IndexGeneratorFactory$IndexHelper, java.time.ZoneId)> has parameter of type <[Lorg.apache.flink.table.types.DataType;> in (IndexGeneratorFactory.java:0)

flink-connector-opensearch-base/src/test/java/org/apache/flink/connector/opensearch/test/DockerImageVersions.java

@@ -22,6 +22,6 @@
  * integration tests.
  */
 public class DockerImageVersions {
-    public static final String OPENSEARCH_1 = "opensearchproject/opensearch:1.3.15";
-    public static final String OPENSEARCH_2 = "opensearchproject/opensearch:2.13.0";
+    public static final String OPENSEARCH_1 = "opensearchproject/opensearch:1.3.19";
+    public static final String OPENSEARCH_2 = "opensearchproject/opensearch:2.17.1";
 }

flink-connector-opensearch/archunit-violations/5c4a6228-f9cb-4828-9625-43c57d133967

@@ -18,6 +18,7 @@
 package org.apache.flink.connector.opensearch.sink;
 
 import org.apache.flink.api.common.operators.MailboxExecutor;
+import org.apache.flink.api.common.operators.MailboxExecutor.MailOptions;
 import org.apache.flink.api.connector.sink2.Sink.InitContext;
 import org.apache.flink.connector.base.DeliveryGuarantee;
 import org.apache.flink.connector.opensearch.sink.BulkResponseInspector.BulkResponseInspectorFactory;
@@ -189,6 +190,18 @@ public void yield() throws InterruptedException, FlinkRuntimeException {}
         public boolean tryYield() throws FlinkRuntimeException {
             return false;
         }
+
+        public void execute(
+                MailOptions mailOptions,
+                ThrowingRunnable<? extends Exception> command,
+                String descriptionFormat,
+                Object... descriptionArgs) {
+            execute(command, descriptionFormat, descriptionArgs);
+        }
+
+        public boolean shouldInterrupt() {
+            return false;
+        }
     }
 
     private OpensearchSinkBuilder<Object> createEmptyBuilder() {

flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilderTest.java

@@ -18,6 +18,7 @@
 package org.apache.flink.connector.opensearch.sink;
 
 import org.apache.flink.api.common.operators.MailboxExecutor;
+import org.apache.flink.api.common.operators.MailboxExecutor.MailOptions;
 import org.apache.flink.api.connector.sink2.SinkWriter;
 import org.apache.flink.api.java.tuple.Tuple2;
 import org.apache.flink.connector.opensearch.OpensearchUtil;
@@ -400,5 +401,17 @@ public void yield() throws InterruptedException, FlinkRuntimeException {
         public boolean tryYield() throws FlinkRuntimeException {
             return false;
         }
+
+        public void execute(
+                MailOptions mailOptions,
+                ThrowingRunnable<? extends Exception> command,
+                String descriptionFormat,
+                Object... descriptionArgs) {
+            execute(command, descriptionFormat, descriptionArgs);
+        }
+
+        public boolean shouldInterrupt() {
+            return false;
+        }
     }
 }

flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/OpensearchWriterITCase.java

@@ -55,7 +55,7 @@ under the License.
 	</modules>
 
 	<properties>
-		<flink.version>1.18.0</flink.version>
+		<flink.version>1.20.0</flink.version>
 		<commons-compress.version>1.26.1</commons-compress.version>
 		<jackson-bom.version>2.16.2</jackson-bom.version>
 		<junit5.version>5.10.2</junit5.version>
@@ -64,7 +64,7 @@ under the License.
 		<mockito.version>3.12.4</mockito.version>
 
 		<japicmp.skip>false</japicmp.skip>
-		<japicmp.referenceVersion>1.0.0-1.16</japicmp.referenceVersion>
+		<japicmp.referenceVersion>1.0.0-1.19</japicmp.referenceVersion>
 
 		<slf4j.version>1.7.36</slf4j.version>
 		<log4j.version>2.17.2</log4j.version>