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 8a79ff1 [hotfix] [opensearch] Fix weekly Github workflow
8a79ff1 is described below
commit 8a79ff1b6db18df67e1b02ab940121dfbed4351c
Author: Andriy Redko <[email protected]>
AuthorDate: Fri Sep 18 14:53:57 2026 -0400
[hotfix] [opensearch] Fix weekly Github workflow
---------
Signed-off-by: Andriy Redko <[email protected]>
---
.github/workflows/weekly.yml | 9 +++------
flink-connector-opensearch-e2e-tests/pom.xml | 1 +
.../connector/opensearch/sink/OpensearchSinkBuilderTest.java | 5 +++--
3 files changed, 7 insertions(+), 8 deletions(-)
diff --git a/.github/workflows/weekly.yml b/.github/workflows/weekly.yml
index 5f7312f..2b02570 100644
--- a/.github/workflows/weekly.yml
+++ b/.github/workflows/weekly.yml
@@ -36,20 +36,17 @@ jobs:
},
{
flink: 1.20-SNAPSHOT,
- jdk: '11, 17, 21',
- branch: main
+ jdk: '8, 11, 17, 21',
+ branch: v1.2
},
{
flink: 1.20.5,
jdk: '8, 11, 17, 21',
- branch: main
+ branch: v1.2
}, {
flink: 1.19.3,
jdk: '8, 11, 17, 21',
branch: v1.2
- }, {
- flink: 1.18.1,
- branch: v1.2
}]
uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
with:
diff --git a/flink-connector-opensearch-e2e-tests/pom.xml
b/flink-connector-opensearch-e2e-tests/pom.xml
index 537f993..576af53 100644
--- a/flink-connector-opensearch-e2e-tests/pom.xml
+++ b/flink-connector-opensearch-e2e-tests/pom.xml
@@ -64,6 +64,7 @@ under the License.
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-test-utils</artifactId>
+ <version>${flink.version}</version>
<scope>test</scope>
</dependency>
<dependency>
diff --git
a/flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilderTest.java
b/flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilderTest.java
index b67118a..c42abc7 100644
---
a/flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilderTest.java
+++
b/flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilderTest.java
@@ -17,12 +17,12 @@
package org.apache.flink.connector.opensearch.sink;
+import org.apache.flink.api.common.operators.MailboxExecutor;
import org.apache.flink.api.connector.sink2.WriterInitContext;
import org.apache.flink.connector.base.DeliveryGuarantee;
import
org.apache.flink.connector.opensearch.sink.BulkResponseInspector.BulkResponseInspectorFactory;
import org.apache.flink.metrics.MetricGroup;
import org.apache.flink.metrics.groups.UnregisteredMetricsGroup;
-import org.apache.flink.runtime.mailbox.SyncMailboxExecutor;
import org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService;
import org.apache.flink.util.SimpleUserCodeClassLoader;
import org.apache.flink.util.TestLoggerExtension;
@@ -161,7 +161,8 @@ class OpensearchSinkBuilderTest {
TestingSinkWriterMetricGroup.getSinkWriterMetricGroup(
new UnregisteredMetricsGroup()));
- Mockito.when(sinkInitContext.getMailboxExecutor()).thenReturn(new
SyncMailboxExecutor());
+ MailboxExecutor executor = Mockito.mock(MailboxExecutor.class);
+
Mockito.when(sinkInitContext.getMailboxExecutor()).thenReturn(executor);
Mockito.when(sinkInitContext.getProcessingTimeService())
.thenReturn(new TestProcessingTimeService());
Mockito.when(sinkInitContext.getUserCodeClassLoader())
