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 5ae7083 [FLINK-39707] Update flink-connector-parent to 2.0.0
5ae7083 is described below
commit 5ae708370d0526e49c9d90a72b3d6e534808d506
Author: mukul-8 <[email protected]>
AuthorDate: Wed May 27 01:28:49 2026 +0530
[FLINK-39707] Update flink-connector-parent to 2.0.0
---
.../5c4a6228-f9cb-4828-9625-43c57d133967 | 2 -
.../opensearch/sink/DefaultFailureHandler.java | 18 ++++++++
.../opensearch/sink/DefaultRestClientConfig.java | 18 ++++++++
.../tests/OpensearchSinkExternalContext.java | 1 +
.../5c4a6228-f9cb-4828-9625-43c57d133967 | 52 ---------------------
.../tests/OpensearchSinkExternalContext.java | 1 +
.../7f6b6846-355a-45b6-9c14-b65accd8d850 | 54 ----------------------
.../opensearch/sink/BulkProcessorConfig.java | 1 +
pom.xml | 25 ++--------
tools/maven/checkstyle.xml | 8 +---
10 files changed, 43 insertions(+), 137 deletions(-)
diff --git
a/flink-connector-opensearch-base/archunit-violations/5c4a6228-f9cb-4828-9625-43c57d133967
b/flink-connector-opensearch-base/archunit-violations/5c4a6228-f9cb-4828-9625-43c57d133967
index dfcc175..5df0504 100644
---
a/flink-connector-opensearch-base/archunit-violations/5c4a6228-f9cb-4828-9625-43c57d133967
+++
b/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)
diff --git
a/flink-connector-opensearch-base/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultFailureHandler.java
b/flink-connector-opensearch-base/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultFailureHandler.java
index c64c0e9..9844718 100644
---
a/flink-connector-opensearch-base/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultFailureHandler.java
+++
b/flink-connector-opensearch-base/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultFailureHandler.java
@@ -1,3 +1,21 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
package org.apache.flink.connector.opensearch.sink;
import org.apache.flink.util.FlinkRuntimeException;
diff --git
a/flink-connector-opensearch-base/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientConfig.java
b/flink-connector-opensearch-base/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientConfig.java
index 312e47f..6970b99 100644
---
a/flink-connector-opensearch-base/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientConfig.java
+++
b/flink-connector-opensearch-base/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientConfig.java
@@ -1,3 +1,21 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
package org.apache.flink.connector.opensearch.sink;
import javax.annotation.Nullable;
diff --git
a/flink-connector-opensearch-e2e-tests/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkExternalContext.java
b/flink-connector-opensearch-e2e-tests/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkExternalContext.java
index f9537da..b320daf 100644
---
a/flink-connector-opensearch-e2e-tests/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkExternalContext.java
+++
b/flink-connector-opensearch-e2e-tests/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkExternalContext.java
@@ -49,6 +49,7 @@ class OpensearchSinkExternalContext
private static final int NUM_RECORDS_LOWER_BOUND = 100;
private static final int BULK_BUFFER = 100;
private static final int PAGE_LENGTH = NUM_RECORDS_UPPER_BOUND + 1;
+
/** The index name. */
private final String indexName;
diff --git
a/flink-connector-opensearch/archunit-violations/5c4a6228-f9cb-4828-9625-43c57d133967
b/flink-connector-opensearch/archunit-violations/5c4a6228-f9cb-4828-9625-43c57d133967
index 4cfbaa4..0cb2b8a 100644
---
a/flink-connector-opensearch/archunit-violations/5c4a6228-f9cb-4828-9625-43c57d133967
+++
b/flink-connector-opensearch/archunit-violations/5c4a6228-f9cb-4828-9625-43c57d133967
@@ -1,57 +1,5 @@
-Constructor
<org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.<init>(org.apache.flink.connector.opensearch.sink.FailureHandler)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(DefaultBulkResponseInspector.java:45)
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)>
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)>
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)>
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)>
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)>
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)>
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)>
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchSink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)>
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchWriter$DefaultRequestIndexer.<init>(org.apache.flink.connector.opensearch.sink.OpensearchWriter,
org.apache.flink.metrics.Counter)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchWriter.java:295)
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchWriter.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.metrics.groups.SinkWriterMetricGroup,
org.apache.flink.api.common.operators.MailboxExecutor,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connecto [...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchWriter.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.metrics.groups.SinkWriterMetricGroup,
org.apache.flink.api.common.operators.MailboxExecutor,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connecto [...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchWriter.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.metrics.groups.SinkWriterMetricGroup,
org.apache.flink.api.common.operators.MailboxExecutor,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connecto [...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchWriter.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.metrics.groups.SinkWriterMetricGroup,
org.apache.flink.api.common.operators.MailboxExecutor,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connecto [...]
-Constructor
<org.apache.flink.connector.opensearch.sink.OpensearchWriter.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.metrics.groups.SinkWriterMetricGroup,
org.apache.flink.api.common.operators.MailboxExecutor,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connecto [...]
-Constructor
<org.apache.flink.connector.opensearch.table.OpensearchDynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat,
org.apache.flink.connector.opensearch.table.OpensearchConfiguration,
java.util.List, org.apache.flink.table.types.DataType, java.lang.String,
java.time.ZoneId)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchDynamicSink.java:69)
-Constructor
<org.apache.flink.connector.opensearch.table.OpensearchDynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat,
org.apache.flink.connector.opensearch.table.OpensearchConfiguration,
java.util.List, org.apache.flink.table.types.DataType, java.lang.String,
java.time.ZoneId)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchDynamicSink.java:70)
-Constructor
<org.apache.flink.connector.opensearch.table.OpensearchDynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat,
org.apache.flink.connector.opensearch.table.OpensearchConfiguration,
java.util.List, org.apache.flink.table.types.DataType, java.lang.String,
java.time.ZoneId)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchDynamicSink.java:71)
-Constructor
<org.apache.flink.connector.opensearch.table.OpensearchDynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat,
org.apache.flink.connector.opensearch.table.OpensearchConfiguration,
java.util.List, org.apache.flink.table.types.DataType, java.lang.String,
java.time.ZoneId)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchDynamicSink.java:72)
-Constructor
<org.apache.flink.connector.opensearch.table.OpensearchDynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat,
org.apache.flink.connector.opensearch.table.OpensearchConfiguration,
java.util.List, org.apache.flink.table.types.DataType, java.lang.String,
java.time.ZoneId)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchDynamicSink.java:73)
-Constructor
<org.apache.flink.connector.opensearch.table.RowOpensearchEmitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator,
org.apache.flink.api.common.serialization.SerializationSchema,
org.opensearch.common.xcontent.XContentType, java.util.function.Function)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(RowOpensearchEmitter.java:56)
-Constructor
<org.apache.flink.connector.opensearch.table.RowOpensearchEmitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator,
org.apache.flink.api.common.serialization.SerializationSchema,
org.opensearch.common.xcontent.XContentType, java.util.function.Function)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(RowOpensearchEmitter.java:57)
-Constructor
<org.apache.flink.connector.opensearch.table.RowOpensearchEmitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator,
org.apache.flink.api.common.serialization.SerializationSchema,
org.opensearch.common.xcontent.XContentType, java.util.function.Function)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(RowOpensearchEmitter.java:58)
-Constructor
<org.apache.flink.connector.opensearch.table.RowOpensearchEmitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator,
org.apache.flink.api.common.serialization.SerializationSchema,
org.opensearch.common.xcontent.XContentType, java.util.function.Function)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(RowOpensearchEmitter.java:59)
Field
<org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.failureHandler>
is annotated with <org.apache.flink.annotation.VisibleForTesting> in
(DefaultBulkResponseInspector.java:0)
-Method
<org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.inspect(org.opensearch.action.bulk.BulkRequest,
org.opensearch.action.bulk.BulkResponse)> calls method
<org.apache.flink.util.ExceptionUtils.firstOrSuppressed(java.lang.Throwable,
java.lang.Throwable)> in (DefaultBulkResponseInspector.java:68)
Method
<org.apache.flink.connector.opensearch.sink.OpensearchSink.getBulkResponseInspectorFactory()>
is annotated with <org.apache.flink.annotation.VisibleForTesting> in
(OpensearchSink.java:0)
Method
<org.apache.flink.connector.opensearch.sink.OpensearchSink.getDeliveryGuarantee()>
is annotated with <org.apache.flink.annotation.VisibleForTesting> in
(OpensearchSink.java:0)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.build()>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:339)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.build()>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:340)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.buildNetworkClientConfig()>
calls method <org.apache.flink.util.Preconditions.checkArgument(boolean,
java.lang.Object)> in (OpensearchSinkBuilder.java:362)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType,
int, long)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:194)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType,
int, long)> calls method
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in
(OpensearchSinkBuilder.java:195)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType,
int, long)> calls method
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in
(OpensearchSinkBuilder.java:198)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType,
int, long)> calls method
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in
(OpensearchSinkBuilder.java:200)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushInterval(long)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (OpensearchSinkBuilder.java:172)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushMaxActions(int)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (OpensearchSinkBuilder.java:143)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkFlushMaxSizeMb(int)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (OpensearchSinkBuilder.java:158)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setBulkResponseInspectorFactory(org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:329)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setConnectionPassword(java.lang.String)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:227)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setConnectionPathPrefix(java.lang.String)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:239)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setConnectionRequestTimeout(int)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (OpensearchSinkBuilder.java:252)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setConnectionTimeout(int)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (OpensearchSinkBuilder.java:264)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setConnectionUsername(java.lang.String)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:215)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setDeliveryGuarantee(org.apache.flink.connector.base.DeliveryGuarantee)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:131)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setDeliveryGuarantee(org.apache.flink.connector.base.DeliveryGuarantee)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (OpensearchSinkBuilder.java:128)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)>
calls method
<org.apache.flink.util.InstantiationUtil.isSerializable(java.lang.Object)> in
(OpensearchSinkBuilder.java:99)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:97)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (OpensearchSinkBuilder.java:98)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setFailureHandler(org.apache.flink.connector.opensearch.sink.FailureHandler)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:314)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setHosts([Lorg.apache.http.HttpHost;)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:114)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setHosts([Lorg.apache.http.HttpHost;)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (OpensearchSinkBuilder.java:115)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setRestClientFactory(org.apache.flink.connector.opensearch.sink.RestClientFactory)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(OpensearchSinkBuilder.java:302)
-Method
<org.apache.flink.connector.opensearch.sink.OpensearchSinkBuilder.setSocketTimeout(int)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (OpensearchSinkBuilder.java:277)
Method
<org.apache.flink.connector.opensearch.sink.OpensearchWriter.blockingFlushAllActions()>
is annotated with <org.apache.flink.annotation.VisibleForTesting> in
(OpensearchWriter.java:0)
Method
<org.apache.flink.connector.opensearch.table.RowOpensearchEmitter$1.getMetricGroup()>
calls constructor
<org.apache.flink.metrics.groups.UnregisteredMetricsGroup.<init>()> in
(RowOpensearchEmitter.java:69)
-Method
<org.apache.flink.connector.opensearch.table.RowOpensearchEmitter$1.getUserCodeClassLoader()>
calls method
<org.apache.flink.util.SimpleUserCodeClassLoader.create(java.lang.ClassLoader)>
in (RowOpensearchEmitter.java:74)
diff --git
a/flink-connector-opensearch2-e2e-tests/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkExternalContext.java
b/flink-connector-opensearch2-e2e-tests/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkExternalContext.java
index 5d1c064..b0c980c 100644
---
a/flink-connector-opensearch2-e2e-tests/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkExternalContext.java
+++
b/flink-connector-opensearch2-e2e-tests/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkExternalContext.java
@@ -49,6 +49,7 @@ class OpensearchSinkExternalContext
private static final int NUM_RECORDS_LOWER_BOUND = 100;
private static final int BULK_BUFFER = 100;
private static final int PAGE_LENGTH = NUM_RECORDS_UPPER_BOUND + 1;
+
/** The index name. */
private final String indexName;
diff --git
a/flink-connector-opensearch2/archunit-violations/7f6b6846-355a-45b6-9c14-b65accd8d850
b/flink-connector-opensearch2/archunit-violations/7f6b6846-355a-45b6-9c14-b65accd8d850
index 9a63c4e..710e62f 100644
---
a/flink-connector-opensearch2/archunit-violations/7f6b6846-355a-45b6-9c14-b65accd8d850
+++
b/flink-connector-opensearch2/archunit-violations/7f6b6846-355a-45b6-9c14-b65accd8d850
@@ -1,60 +1,6 @@
-Constructor
<org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.<init>(org.apache.flink.connector.opensearch.sink.FailureHandler)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(DefaultBulkResponseInspector.java:42)
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Sink.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter,
org.apache.flink.connector.base.DeliveryGuarantee,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)
[...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Writer$DefaultBulkResponseInspector.<init>(org.apache.flink.connector.opensearch.sink.FailureHandler)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2Writer.java:341)
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Writer$DefaultRequestIndexer.<init>(org.apache.flink.connector.opensearch.sink.Opensearch2Writer,
org.apache.flink.metrics.Counter)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2Writer.java:297)
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Writer.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.metrics.groups.SinkWriterMetricGroup,
org.apache.flink.api.common.operators.MailboxExecutor,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connect [...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Writer.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.metrics.groups.SinkWriterMetricGroup,
org.apache.flink.api.common.operators.MailboxExecutor,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connect [...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Writer.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.metrics.groups.SinkWriterMetricGroup,
org.apache.flink.api.common.operators.MailboxExecutor,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connect [...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Writer.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.metrics.groups.SinkWriterMetricGroup,
org.apache.flink.api.common.operators.MailboxExecutor,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connect [...]
-Constructor
<org.apache.flink.connector.opensearch.sink.Opensearch2Writer.<init>(java.util.List,
org.apache.flink.connector.opensearch.sink.OpensearchEmitter, boolean,
org.apache.flink.connector.opensearch.sink.BulkProcessorConfig,
org.apache.flink.connector.opensearch.sink.NetworkClientConfig,
org.apache.flink.metrics.groups.SinkWriterMetricGroup,
org.apache.flink.api.common.operators.MailboxExecutor,
org.apache.flink.connector.opensearch.sink.RestClientFactory,
org.apache.flink.connect [...]
-Constructor
<org.apache.flink.connector.opensearch.table.Opensearch2DynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat,
org.apache.flink.connector.opensearch.table.OpensearchConfiguration,
java.util.List, org.apache.flink.table.types.DataType, java.lang.String,
java.time.ZoneId)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2DynamicSink.java:69)
-Constructor
<org.apache.flink.connector.opensearch.table.Opensearch2DynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat,
org.apache.flink.connector.opensearch.table.OpensearchConfiguration,
java.util.List, org.apache.flink.table.types.DataType, java.lang.String,
java.time.ZoneId)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2DynamicSink.java:70)
-Constructor
<org.apache.flink.connector.opensearch.table.Opensearch2DynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat,
org.apache.flink.connector.opensearch.table.OpensearchConfiguration,
java.util.List, org.apache.flink.table.types.DataType, java.lang.String,
java.time.ZoneId)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2DynamicSink.java:71)
-Constructor
<org.apache.flink.connector.opensearch.table.Opensearch2DynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat,
org.apache.flink.connector.opensearch.table.OpensearchConfiguration,
java.util.List, org.apache.flink.table.types.DataType, java.lang.String,
java.time.ZoneId)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2DynamicSink.java:72)
-Constructor
<org.apache.flink.connector.opensearch.table.Opensearch2DynamicSink.<init>(org.apache.flink.table.connector.format.EncodingFormat,
org.apache.flink.connector.opensearch.table.OpensearchConfiguration,
java.util.List, org.apache.flink.table.types.DataType, java.lang.String,
java.time.ZoneId)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2DynamicSink.java:73)
-Constructor
<org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator,
org.apache.flink.api.common.serialization.SerializationSchema,
org.opensearch.common.xcontent.XContentType, java.util.function.Function)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(RowOpensearch2Emitter.java:56)
-Constructor
<org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator,
org.apache.flink.api.common.serialization.SerializationSchema,
org.opensearch.common.xcontent.XContentType, java.util.function.Function)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(RowOpensearch2Emitter.java:57)
-Constructor
<org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator,
org.apache.flink.api.common.serialization.SerializationSchema,
org.opensearch.common.xcontent.XContentType, java.util.function.Function)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(RowOpensearch2Emitter.java:58)
-Constructor
<org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter.<init>(org.apache.flink.connector.opensearch.table.IndexGenerator,
org.apache.flink.api.common.serialization.SerializationSchema,
org.opensearch.common.xcontent.XContentType, java.util.function.Function)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(RowOpensearch2Emitter.java:59)
Field
<org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.failureHandler>
is annotated with <org.apache.flink.annotation.VisibleForTesting> in
(DefaultBulkResponseInspector.java:0)
Field
<org.apache.flink.connector.opensearch.sink.Opensearch2Writer$DefaultBulkResponseInspector.failureHandler>
is annotated with <org.apache.flink.annotation.VisibleForTesting> in
(Opensearch2Writer.java:0)
-Method
<org.apache.flink.connector.opensearch.sink.DefaultBulkResponseInspector.inspect(org.opensearch.action.bulk.BulkRequest,
org.opensearch.action.bulk.BulkResponse)> calls method
<org.apache.flink.util.ExceptionUtils.firstOrSuppressed(java.lang.Throwable,
java.lang.Throwable)> in (DefaultBulkResponseInspector.java:65)
Method
<org.apache.flink.connector.opensearch.sink.Opensearch2Sink.getBulkResponseInspectorFactory()>
is annotated with <org.apache.flink.annotation.VisibleForTesting> in
(Opensearch2Sink.java:0)
Method
<org.apache.flink.connector.opensearch.sink.Opensearch2Sink.getDeliveryGuarantee()>
is annotated with <org.apache.flink.annotation.VisibleForTesting> in
(Opensearch2Sink.java:0)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.build()>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:339)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.build()>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:340)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.buildNetworkClientConfig()>
calls method <org.apache.flink.util.Preconditions.checkArgument(boolean,
java.lang.Object)> in (Opensearch2SinkBuilder.java:362)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType,
int, long)> calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:194)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType,
int, long)> calls method
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in
(Opensearch2SinkBuilder.java:195)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType,
int, long)> calls method
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in
(Opensearch2SinkBuilder.java:198)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushBackoffStrategy(org.apache.flink.connector.opensearch.sink.FlushBackoffType,
int, long)> calls method
<org.apache.flink.util.Preconditions.checkState(boolean, java.lang.Object)> in
(Opensearch2SinkBuilder.java:200)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushInterval(long)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (Opensearch2SinkBuilder.java:172)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushMaxActions(int)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (Opensearch2SinkBuilder.java:143)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkFlushMaxSizeMb(int)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (Opensearch2SinkBuilder.java:158)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setBulkResponseInspectorFactory(org.apache.flink.connector.opensearch.sink.BulkResponseInspector$BulkResponseInspectorFactory)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:329)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setConnectionPassword(java.lang.String)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:227)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setConnectionPathPrefix(java.lang.String)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:239)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setConnectionRequestTimeout(int)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (Opensearch2SinkBuilder.java:252)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setConnectionTimeout(int)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (Opensearch2SinkBuilder.java:264)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setConnectionUsername(java.lang.String)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:215)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setDeliveryGuarantee(org.apache.flink.connector.base.DeliveryGuarantee)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:131)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setDeliveryGuarantee(org.apache.flink.connector.base.DeliveryGuarantee)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (Opensearch2SinkBuilder.java:128)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)>
calls method
<org.apache.flink.util.InstantiationUtil.isSerializable(java.lang.Object)> in
(Opensearch2SinkBuilder.java:99)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:97)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setEmitter(org.apache.flink.connector.opensearch.sink.OpensearchEmitter)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (Opensearch2SinkBuilder.java:98)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setFailureHandler(org.apache.flink.connector.opensearch.sink.FailureHandler)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:314)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setHosts([Lorg.apache.http.HttpHost;)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:114)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setHosts([Lorg.apache.http.HttpHost;)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (Opensearch2SinkBuilder.java:115)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setRestClientFactory(org.apache.flink.connector.opensearch.sink.RestClientFactory)>
calls method
<org.apache.flink.util.Preconditions.checkNotNull(java.lang.Object)> in
(Opensearch2SinkBuilder.java:302)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2SinkBuilder.setSocketTimeout(int)>
calls method <org.apache.flink.util.Preconditions.checkState(boolean,
java.lang.Object)> in (Opensearch2SinkBuilder.java:277)
-Method
<org.apache.flink.connector.opensearch.sink.Opensearch2Writer$DefaultBulkResponseInspector.inspect(org.opensearch.action.bulk.BulkRequest,
org.opensearch.action.bulk.BulkResponse)> calls method
<org.apache.flink.util.ExceptionUtils.firstOrSuppressed(java.lang.Throwable,
java.lang.Throwable)> in (Opensearch2Writer.java:364)
Method
<org.apache.flink.connector.opensearch.sink.Opensearch2Writer.blockingFlushAllActions()>
is annotated with <org.apache.flink.annotation.VisibleForTesting> in
(Opensearch2Writer.java:0)
Method
<org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter$1.getMetricGroup()>
calls constructor
<org.apache.flink.metrics.groups.UnregisteredMetricsGroup.<init>()> in
(RowOpensearch2Emitter.java:69)
-Method
<org.apache.flink.connector.opensearch.table.RowOpensearch2Emitter$1.getUserCodeClassLoader()>
calls method
<org.apache.flink.util.SimpleUserCodeClassLoader.create(java.lang.ClassLoader)>
in (RowOpensearch2Emitter.java:74)
diff --git
a/flink-connector-opensearch3/src/main/java/org/apache/flink/connector/opensearch/sink/BulkProcessorConfig.java
b/flink-connector-opensearch3/src/main/java/org/apache/flink/connector/opensearch/sink/BulkProcessorConfig.java
index 405283a..bd4e7ff 100644
---
a/flink-connector-opensearch3/src/main/java/org/apache/flink/connector/opensearch/sink/BulkProcessorConfig.java
+++
b/flink-connector-opensearch3/src/main/java/org/apache/flink/connector/opensearch/sink/BulkProcessorConfig.java
@@ -28,6 +28,7 @@ class BulkProcessorConfig implements Serializable {
private static final long serialVersionUID = 1L;
private final int bulkFlushMaxActions;
+
/** -1 if bulk flush max size is disabled; otherwise max buffered bulk
payload in bytes. */
private final long bulkFlushMaxBytes;
diff --git a/pom.xml b/pom.xml
index 81bae79..71b3f6c 100644
--- a/pom.xml
+++ b/pom.xml
@@ -22,7 +22,7 @@ under the License.
<parent>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-parent</artifactId>
- <version>1.1.0</version>
+ <version>2.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -430,26 +430,7 @@ under the License.
<module>flink-sql-connector-opensearch3</module>
</modules>
</profile>
- <!-- The spotless comes from flink-connector-parent and needs
version bump to support JDK-21 -->
- <!-- Remove this profile once we drop the support of 1.x
release line -->
- <profile>
- <id>spotless</id>
- <activation>
- <jdk>[21,)</jdk>
- </activation>
- <build>
- <plugins>
- <plugin>
-
<groupId>com.diffplug.spotless</groupId>
-
<artifactId>spotless-maven-plugin</artifactId>
- <configuration>
- <skip>true</skip>
- </configuration>
- </plugin>
- </plugins>
- </build>
- </profile>
- </profiles>
+ </profiles>
<build>
<plugins>
@@ -474,7 +455,7 @@ under the License.
<plugin>
<!-- activate API compatibility checks -->
- <groupId>io.github.zentol.japicmp</groupId>
+ <groupId>com.github.siom79.japicmp</groupId>
<artifactId>japicmp-maven-plugin</artifactId>
</plugin>
diff --git a/tools/maven/checkstyle.xml b/tools/maven/checkstyle.xml
index 2048fd1..12613b9 100644
--- a/tools/maven/checkstyle.xml
+++ b/tools/maven/checkstyle.xml
@@ -271,16 +271,10 @@ This file is based on the checkstyle file of Apache Beam.
<!-- Checks for Javadoc comments. -->
<!-- See http://checkstyle.sf.net/config_javadoc.html -->
<module name="JavadocMethod">
- <property name="scope" value="protected"/>
+ <property name="accessModifiers" value="protected"/>
<property name="severity" value="error"/>
- <property name="allowMissingJavadoc" value="true"/>
<property name="allowMissingParamTags" value="true"/>
<property name="allowMissingReturnTag" value="true"/>
- <property name="allowMissingThrowsTags" value="true"/>
- <property name="allowThrowsTagsForSubclasses"
value="true"/>
- <property name="allowUndeclaredRTE" value="true"/>
- <!-- This check sometimes failed for with "Unable to
get class information for @throws tag" for custom exceptions -->
- <property name="suppressLoadErrors" value="true"/>
</module>
<!-- Check that paragraph tags are used correctly in Javadoc.
-->
