From dfd01fbe325bbd646f83fea65a96b776356abd32 Mon Sep 17 00:00:00 2001 From: Mukul Gupta Date: Thu, 21 May 2026 04:27:48 +0000 Subject: [PATCH] [FLINK-39707] Update flink-connector-parent to 2.0.0 --- .../5c4a6228-f9cb-4828-9625-43c57d133967 | 2 - .../sink/DefaultFailureHandler.java | 18 +++++++ .../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 (int, int, long, org.apache.flink.connector.opensearch.sink.FlushBackoffType, int, long)> calls method in (BulkProcessorConfig.java:44) -Constructor (org.apache.flink.configuration.ReadableConfig)> calls method in (OpensearchConfiguration.java:61) Method 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.FailureHandler)> calls method in (DefaultBulkResponseInspector.java:45) -Constructor (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)> calls method in (OpensearchSink.java:75) -Constructor (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)> calls method in (OpensearchSink.java:74) -Constructor (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)> calls method in (OpensearchSink.java:76) -Constructor (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)> calls method in (OpensearchSink.java:77) -Constructor (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)> calls method in (OpensearchSink.java:78) -Constructor (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)> calls method in (OpensearchSink.java:79) -Constructor (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)> calls method in (OpensearchSink.java:80) -Constructor (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)> calls method in (OpensearchSink.java:81) -Constructor (org.apache.flink.connector.opensearch.sink.OpensearchWriter, org.apache.flink.metrics.Counter)> calls method in (OpensearchWriter.java:295) -Constructor (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.connector.opensearch.sink.BulkResponseInspector)> calls method in (OpensearchWriter.java:100) -Constructor (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.connector.opensearch.sink.BulkResponseInspector)> calls method in (OpensearchWriter.java:102) -Constructor (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.connector.opensearch.sink.BulkResponseInspector)> calls method in (OpensearchWriter.java:105) -Constructor (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.connector.opensearch.sink.BulkResponseInspector)> calls method in (OpensearchWriter.java:111) -Constructor (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.connector.opensearch.sink.BulkResponseInspector)> calls method in (OpensearchWriter.java:113) -Constructor (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 in (OpensearchDynamicSink.java:69) -Constructor (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 in (OpensearchDynamicSink.java:70) -Constructor (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 in (OpensearchDynamicSink.java:71) -Constructor (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 in (OpensearchDynamicSink.java:72) -Constructor (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 in (OpensearchDynamicSink.java:73) -Constructor (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 in (RowOpensearchEmitter.java:56) -Constructor (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 in (RowOpensearchEmitter.java:57) -Constructor (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 in (RowOpensearchEmitter.java:58) -Constructor (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 in (RowOpensearchEmitter.java:59) Field is annotated with in (DefaultBulkResponseInspector.java:0) -Method calls method in (DefaultBulkResponseInspector.java:68) Method is annotated with in (OpensearchSink.java:0) Method is annotated with in (OpensearchSink.java:0) -Method calls method in (OpensearchSinkBuilder.java:339) -Method calls method in (OpensearchSinkBuilder.java:340) -Method calls method in (OpensearchSinkBuilder.java:362) -Method calls method in (OpensearchSinkBuilder.java:194) -Method calls method in (OpensearchSinkBuilder.java:195) -Method calls method in (OpensearchSinkBuilder.java:198) -Method calls method in (OpensearchSinkBuilder.java:200) -Method calls method in (OpensearchSinkBuilder.java:172) -Method calls method in (OpensearchSinkBuilder.java:143) -Method calls method in (OpensearchSinkBuilder.java:158) -Method calls method in (OpensearchSinkBuilder.java:329) -Method calls method in (OpensearchSinkBuilder.java:227) -Method calls method in (OpensearchSinkBuilder.java:239) -Method calls method in (OpensearchSinkBuilder.java:252) -Method calls method in (OpensearchSinkBuilder.java:264) -Method calls method in (OpensearchSinkBuilder.java:215) -Method calls method in (OpensearchSinkBuilder.java:131) -Method calls method in (OpensearchSinkBuilder.java:128) -Method calls method in (OpensearchSinkBuilder.java:99) -Method calls method in (OpensearchSinkBuilder.java:97) -Method calls method in (OpensearchSinkBuilder.java:98) -Method calls method in (OpensearchSinkBuilder.java:314) -Method calls method in (OpensearchSinkBuilder.java:114) -Method calls method in (OpensearchSinkBuilder.java:115) -Method calls method in (OpensearchSinkBuilder.java:302) -Method calls method in (OpensearchSinkBuilder.java:277) Method is annotated with in (OpensearchWriter.java:0) Method calls constructor ()> in (RowOpensearchEmitter.java:69) -Method calls method 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.FailureHandler)> calls method in (DefaultBulkResponseInspector.java:42) -Constructor (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)> calls method in (Opensearch2Sink.java:75) -Constructor (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)> calls method in (Opensearch2Sink.java:74) -Constructor (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)> calls method in (Opensearch2Sink.java:76) -Constructor (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)> calls method in (Opensearch2Sink.java:77) -Constructor (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)> calls method in (Opensearch2Sink.java:78) -Constructor (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)> calls method in (Opensearch2Sink.java:79) -Constructor (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)> calls method in (Opensearch2Sink.java:80) -Constructor (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)> calls method in (Opensearch2Sink.java:81) -Constructor (org.apache.flink.connector.opensearch.sink.FailureHandler)> calls method in (Opensearch2Writer.java:341) -Constructor (org.apache.flink.connector.opensearch.sink.Opensearch2Writer, org.apache.flink.metrics.Counter)> calls method in (Opensearch2Writer.java:297) -Constructor (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.connector.opensearch.sink.BulkResponseInspector)> calls method in (Opensearch2Writer.java:102) -Constructor (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.connector.opensearch.sink.BulkResponseInspector)> calls method in (Opensearch2Writer.java:104) -Constructor (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.connector.opensearch.sink.BulkResponseInspector)> calls method in (Opensearch2Writer.java:107) -Constructor (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.connector.opensearch.sink.BulkResponseInspector)> calls method in (Opensearch2Writer.java:113) -Constructor (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.connector.opensearch.sink.BulkResponseInspector)> calls method in (Opensearch2Writer.java:115) -Constructor (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 in (Opensearch2DynamicSink.java:69) -Constructor (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 in (Opensearch2DynamicSink.java:70) -Constructor (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 in (Opensearch2DynamicSink.java:71) -Constructor (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 in (Opensearch2DynamicSink.java:72) -Constructor (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 in (Opensearch2DynamicSink.java:73) -Constructor (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 in (RowOpensearch2Emitter.java:56) -Constructor (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 in (RowOpensearch2Emitter.java:57) -Constructor (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 in (RowOpensearch2Emitter.java:58) -Constructor (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 in (RowOpensearch2Emitter.java:59) Field is annotated with in (DefaultBulkResponseInspector.java:0) Field is annotated with in (Opensearch2Writer.java:0) -Method calls method in (DefaultBulkResponseInspector.java:65) Method is annotated with in (Opensearch2Sink.java:0) Method is annotated with in (Opensearch2Sink.java:0) -Method calls method in (Opensearch2SinkBuilder.java:339) -Method calls method in (Opensearch2SinkBuilder.java:340) -Method calls method in (Opensearch2SinkBuilder.java:362) -Method calls method in (Opensearch2SinkBuilder.java:194) -Method calls method in (Opensearch2SinkBuilder.java:195) -Method calls method in (Opensearch2SinkBuilder.java:198) -Method calls method in (Opensearch2SinkBuilder.java:200) -Method calls method in (Opensearch2SinkBuilder.java:172) -Method calls method in (Opensearch2SinkBuilder.java:143) -Method calls method in (Opensearch2SinkBuilder.java:158) -Method calls method in (Opensearch2SinkBuilder.java:329) -Method calls method in (Opensearch2SinkBuilder.java:227) -Method calls method in (Opensearch2SinkBuilder.java:239) -Method calls method in (Opensearch2SinkBuilder.java:252) -Method calls method in (Opensearch2SinkBuilder.java:264) -Method calls method in (Opensearch2SinkBuilder.java:215) -Method calls method in (Opensearch2SinkBuilder.java:131) -Method calls method in (Opensearch2SinkBuilder.java:128) -Method calls method in (Opensearch2SinkBuilder.java:99) -Method calls method in (Opensearch2SinkBuilder.java:97) -Method calls method in (Opensearch2SinkBuilder.java:98) -Method calls method in (Opensearch2SinkBuilder.java:314) -Method calls method in (Opensearch2SinkBuilder.java:114) -Method calls method in (Opensearch2SinkBuilder.java:115) -Method calls method in (Opensearch2SinkBuilder.java:302) -Method calls method in (Opensearch2SinkBuilder.java:277) -Method calls method in (Opensearch2Writer.java:364) Method is annotated with in (Opensearch2Writer.java:0) Method calls constructor ()> in (RowOpensearch2Emitter.java:69) -Method calls method 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. org.apache.flink flink-connector-parent - 1.1.0 + 2.0.0 4.0.0 @@ -430,26 +430,7 @@ under the License. flink-sql-connector-opensearch3 - - - - spotless - - [21,) - - - - - com.diffplug.spotless - spotless-maven-plugin - - true - - - - - - + @@ -474,7 +455,7 @@ under the License. - io.github.zentol.japicmp + com.github.siom79.japicmp japicmp-maven-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. - + - - - - - -