This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-opensearch.git
from a4367c7 [FLINK-34961] Use dedicated CI name for Opensearch connector
to differentiate it in infra-reports
new 209be92 [FLINK-33859] Support OpenSearch v2
new 0017525 [hotfix] Apply for Opensearch 2.13.0 and 1.3.15
new 22a2934 [hotfix] Introduce profiles for releasing connectors for
Opensearch 1 and 2
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/push_pr.yml | 6 +-
.../docs/connectors/datastream/opensearch.md | 2 +-
.../docs/connectors/datastream/opensearch.md | 2 +-
.../0c16f106-1632-4ba5-aa26-eb3ab7c7d43e | 0
.../0c6c8466-9ce6-41a7-b6dd-947cc5702975 | 0
.../4382f1f0-807a-45ff-97d8-42f72b6e9484 | 0
.../5c4a6228-f9cb-4828-9625-43c57d133967 | 3 +
.../73099dba-7f06-4637-b2ad-b3c906aaaf1c | 0
.../7c5588a1-e67a-4f85-a1c2-6be9dfe44c09 | 0
.../85d671bb-83fe-41ff-bc35-bd171908a156 | 0
.../879defc0-4d7e-43cb-ace6-1eb5aec9bac5 | 0
.../c921f20b-c7ee-4fd5-a8e9-c19ac7a59f20 | 0
.../archunit-violations/stored.rules | 3 +-
.../pom.xml | 8 +-
.../opensearch/sink/BulkProcessorConfig.java | 0
.../opensearch/sink/BulkResponseInspector.java | 0
.../opensearch/sink/DefaultFailureHandler.java | 14 ++++
.../opensearch/sink/DefaultRestClientConfig.java | 0
.../opensearch/sink/DefaultRestClientFactory.java | 0
.../connector/opensearch/sink/FailureHandler.java | 0
.../opensearch/sink/FlushBackoffType.java | 0
.../opensearch/sink/NetworkClientConfig.java | 0
.../opensearch/sink/OpensearchEmitter.java | 0
.../connector/opensearch/sink/RequestIndexer.java | 0
.../opensearch/sink/RestClientFactory.java | 0
.../table/AbstractTimeIndexGenerator.java | 0
.../connector/opensearch/table/IndexGenerator.java | 0
.../opensearch/table/IndexGeneratorBase.java | 0
.../opensearch/table/IndexGeneratorFactory.java | 0
.../connector/opensearch/table/KeyExtractor.java | 0
.../opensearch/table/LogicalTypeWithIndex.java | 0
.../opensearch/table/OpensearchConfiguration.java | 0
.../table/OpensearchConnectorOptions.java | 0
.../table/OpensearchValidationUtils.java | 0
.../opensearch/table/StaticIndexGenerator.java | 0
.../opensearch/ActionRequestFailureHandler.java | 0
.../opensearch/BufferingNoOpRequestIndexer.java | 0
.../opensearch/OpensearchBulkProcessorIndexer.java | 0
.../opensearch/OpensearchSinkFunction.java | 0
.../connectors/opensearch/RequestIndexer.java | 0
.../connectors/opensearch/RestClientFactory.java | 0
.../opensearch/util/NoOpFailureHandler.java | 0
.../ProductionCodeArchitectureTest.java | 0
.../architecture/TestCodeArchitectureTest.java | 0
.../flink/connector/opensearch/OpensearchUtil.java | 0
.../opensearch/sink/OpensearchTestClient.java | 0
.../sink/TestingSinkWriterMetricGroup.java | 0
.../opensearch/table/IndexGeneratorTest.java | 0
.../opensearch/table/KeyExtractorTest.java | 0
.../connector/opensearch/table/TestContext.java | 0
.../opensearch/test/DockerImageVersions.java | 3 +-
.../testutils/SourceSinkDataTestKit.java | 0
.../src/test/resources/archunit.properties | 0
.../src/test/resources/log4j2-test.properties | 0
flink-connector-opensearch-e2e-tests/pom.xml | 19 ++++-
.../4382f1f0-807a-45ff-97d8-42f72b6e9484 | 20 +----
.../5c4a6228-f9cb-4828-9625-43c57d133967 | 57 +++++++++++++
.../archunit-violations/stored.rules | 3 +-
flink-connector-opensearch/pom.xml | 41 ++++-----
.../sink/BulkRequestConsumerFactory.java | 35 --------
.../sink/DefaultBulkResponseInspector.java | 91 ++++++++++++++++++++
.../opensearch/sink/OpensearchSinkBuilder.java | 2 -
.../opensearch/sink/OpensearchWriter.java | 63 ++------------
.../opensearch/sink/DefaultBulkInspectorTest.java | 1 -
.../opensearch/sink/OpensearchSinkBuilderTest.java | 1 -
.../opensearch/sink/OpensearchWriterITCase.java | 2 -
.../pom.xml | 28 +++++--
.../flink/streaming/tests/ComparableTuple2.java | 0
.../streaming/tests/OpensearchSinkExample.java | 6 +-
.../streaming/tests/OpensearchTestEmitter.java | 0
.../flink/core/execution/CheckpointingMode.java | 0
.../streaming/tests/OpensearchDataReader.java | 0
.../streaming/tests/OpensearchSinkE2ECase.java | 6 +-
.../tests/OpensearchSinkExternalContext.java | 4 +-
.../OpensearchSinkExternalContextFactory.java | 0
.../streaming/tests/OpensearchTestClient.java | 2 +-
.../src/test/resources/log4j2-test.properties | 0
.../0c16f106-1632-4ba5-aa26-eb3ab7c7d43e | 0
.../0c6c8466-9ce6-41a7-b6dd-947cc5702975 | 0
.../4382f1f0-807a-45ff-97d8-42f72b6e9484 | 18 ++++
.../73099dba-7f06-4637-b2ad-b3c906aaaf1c | 0
.../7c5588a1-e67a-4f85-a1c2-6be9dfe44c09 | 0
.../7f6b6846-355a-45b6-9c14-b65accd8d850 | 60 +++++++++++++
.../85d671bb-83fe-41ff-bc35-bd171908a156 | 0
.../879defc0-4d7e-43cb-ace6-1eb5aec9bac5 | 0
.../c921f20b-c7ee-4fd5-a8e9-c19ac7a59f20 | 0
.../archunit-violations/stored.rules | 3 +-
.../pom.xml | 65 +++++++++++++--
.../sink/DefaultBulkResponseInspector.java | 88 ++++++++++++++++++++
.../connector/opensearch/sink/Opensearch2Sink.java | 8 +-
.../opensearch/sink/Opensearch2SinkBuilder.java | 62 +++++++-------
.../opensearch/sink/Opensearch2Writer.java | 20 +++--
.../opensearch/table/Opensearch2DynamicSink.java | 20 ++---
.../table/Opensearch2DynamicSinkFactory.java | 8 +-
.../table/Opensearch2SinkBuilderSupplier.java | 4 +-
.../opensearch/table/RowOpensearch2Emitter.java | 6 +-
.../connectors/opensearch/Opensearch2Sink.java | 30 +++----
.../org.apache.flink.table.factories.Factory | 2 +-
.../ProductionCodeArchitectureTest.java | 0
.../architecture/TestCodeArchitectureTest.java | 0
.../sink/DefaultBulkResponseInspectorTest.java | 15 +---
.../sink/Opensearch2SinkBuilderTest.java | 97 ++--------------------
.../opensearch/sink/Opensearch2SinkITCase.java | 18 ++--
.../opensearch/sink/Opensearch2TestClient.java | 4 +-
.../opensearch/sink/Opensearch2WriterITCase.java | 44 +++++-----
.../connector/opensearch/sink/TestEmitter.java | 2 +-
.../opensearch/table/IndexGeneratorTest.java | 0
.../opensearch/table/KeyExtractorTest.java | 0
.../table/Opensearch2DynamicSinkFactoryTest.java | 30 +++----
.../table/Opensearch2DynamicSinkITCase.java | 12 +--
.../connector/opensearch/table/TestContext.java | 0
.../opensearch/Opensearch2SinkITCase.java | 20 ++---
.../connectors/opensearch/Opensearch2SinkTest.java | 77 ++++++++---------
.../testutils/SourceSinkDataTestKit.java | 2 +-
.../src/test/resources/archunit.properties | 2 +-
.../src/test/resources/log4j2-test.properties | 0
flink-sql-connector-opensearch/pom.xml | 10 ++-
.../src/main/resources/META-INF/NOTICE | 34 ++++----
.../pom.xml | 66 +++++++++++----
.../src/main/resources/META-INF/NOTICE | 57 +++++++++++++
.../connector/opensearch2}/PackagingITCase.java | 5 +-
pom.xml | 52 ++++++++++--
122 files changed, 853 insertions(+), 510 deletions(-)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/archunit-violations/0c16f106-1632-4ba5-aa26-eb3ab7c7d43e
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/archunit-violations/0c6c8466-9ce6-41a7-b6dd-947cc5702975
(100%)
copy
flink-connector-opensearch/archunit-violations/0c16f106-1632-4ba5-aa26-eb3ab7c7d43e
=>
flink-connector-opensearch-base/archunit-violations/4382f1f0-807a-45ff-97d8-42f72b6e9484
(100%)
create mode 100644
flink-connector-opensearch-base/archunit-violations/5c4a6228-f9cb-4828-9625-43c57d133967
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/archunit-violations/73099dba-7f06-4637-b2ad-b3c906aaaf1c
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/archunit-violations/7c5588a1-e67a-4f85-a1c2-6be9dfe44c09
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/archunit-violations/85d671bb-83fe-41ff-bc35-bd171908a156
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/archunit-violations/879defc0-4d7e-43cb-ace6-1eb5aec9bac5
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/archunit-violations/c921f20b-c7ee-4fd5-a8e9-c19ac7a59f20
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/archunit-violations/stored.rules (85%)
copy {flink-connector-opensearch => flink-connector-opensearch-base}/pom.xml
(96%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/sink/BulkProcessorConfig.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/sink/BulkResponseInspector.java
(100%)
create mode 100644
flink-connector-opensearch-base/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultFailureHandler.java
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientConfig.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultRestClientFactory.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/sink/FailureHandler.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/sink/FlushBackoffType.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/sink/NetworkClientConfig.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchEmitter.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/sink/RequestIndexer.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/sink/RestClientFactory.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/table/AbstractTimeIndexGenerator.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/table/IndexGenerator.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/table/IndexGeneratorBase.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/table/IndexGeneratorFactory.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/table/KeyExtractor.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/table/LogicalTypeWithIndex.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchConfiguration.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchConnectorOptions.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchValidationUtils.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/connector/opensearch/table/StaticIndexGenerator.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/streaming/connectors/opensearch/ActionRequestFailureHandler.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/streaming/connectors/opensearch/BufferingNoOpRequestIndexer.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/streaming/connectors/opensearch/OpensearchBulkProcessorIndexer.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSinkFunction.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/streaming/connectors/opensearch/RequestIndexer.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/streaming/connectors/opensearch/RestClientFactory.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/main/java/org/apache/flink/streaming/connectors/opensearch/util/NoOpFailureHandler.java
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/java/org/apache/flink/architecture/ProductionCodeArchitectureTest.java
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/java/org/apache/flink/connector/opensearch/OpensearchUtil.java
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/java/org/apache/flink/connector/opensearch/sink/OpensearchTestClient.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/java/org/apache/flink/connector/opensearch/sink/TestingSinkWriterMetricGroup.java
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/java/org/apache/flink/connector/opensearch/table/IndexGeneratorTest.java
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/java/org/apache/flink/connector/opensearch/table/KeyExtractorTest.java
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/java/org/apache/flink/connector/opensearch/table/TestContext.java
(100%)
rename {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/java/org/apache/flink/connector/opensearch/test/DockerImageVersions.java
(91%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/java/org/apache/flink/streaming/connectors/opensearch/testutils/SourceSinkDataTestKit.java
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/resources/archunit.properties (100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch-base}/src/test/resources/log4j2-test.properties
(100%)
create mode 100644
flink-connector-opensearch/archunit-violations/5c4a6228-f9cb-4828-9625-43c57d133967
delete mode 100644
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/BulkRequestConsumerFactory.java
create mode 100644
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultBulkResponseInspector.java
copy {flink-connector-opensearch-e2e-tests =>
flink-connector-opensearch2-e2e-tests}/pom.xml (86%)
copy {flink-connector-opensearch-e2e-tests =>
flink-connector-opensearch2-e2e-tests}/src/main/java/org/apache/flink/streaming/tests/ComparableTuple2.java
(100%)
copy {flink-connector-opensearch-e2e-tests =>
flink-connector-opensearch2-e2e-tests}/src/main/java/org/apache/flink/streaming/tests/OpensearchSinkExample.java
(97%)
copy {flink-connector-opensearch-e2e-tests =>
flink-connector-opensearch2-e2e-tests}/src/main/java/org/apache/flink/streaming/tests/OpensearchTestEmitter.java
(100%)
copy {flink-connector-opensearch-e2e-tests =>
flink-connector-opensearch2-e2e-tests}/src/test/java/org/apache/flink/core/execution/CheckpointingMode.java
(100%)
copy {flink-connector-opensearch-e2e-tests =>
flink-connector-opensearch2-e2e-tests}/src/test/java/org/apache/flink/streaming/tests/OpensearchDataReader.java
(100%)
copy {flink-connector-opensearch-e2e-tests =>
flink-connector-opensearch2-e2e-tests}/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkE2ECase.java
(97%)
copy {flink-connector-opensearch-e2e-tests =>
flink-connector-opensearch2-e2e-tests}/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkExternalContext.java
(97%)
copy {flink-connector-opensearch-e2e-tests =>
flink-connector-opensearch2-e2e-tests}/src/test/java/org/apache/flink/streaming/tests/OpensearchSinkExternalContextFactory.java
(100%)
copy {flink-connector-opensearch-e2e-tests =>
flink-connector-opensearch2-e2e-tests}/src/test/java/org/apache/flink/streaming/tests/OpensearchTestClient.java
(99%)
copy {flink-connector-opensearch-e2e-tests =>
flink-connector-opensearch2-e2e-tests}/src/test/resources/log4j2-test.properties
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/archunit-violations/0c16f106-1632-4ba5-aa26-eb3ab7c7d43e
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/archunit-violations/0c6c8466-9ce6-41a7-b6dd-947cc5702975
(100%)
create mode 100644
flink-connector-opensearch2/archunit-violations/4382f1f0-807a-45ff-97d8-42f72b6e9484
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/archunit-violations/73099dba-7f06-4637-b2ad-b3c906aaaf1c
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/archunit-violations/7c5588a1-e67a-4f85-a1c2-6be9dfe44c09
(100%)
create mode 100644
flink-connector-opensearch2/archunit-violations/7f6b6846-355a-45b6-9c14-b65accd8d850
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/archunit-violations/85d671bb-83fe-41ff-bc35-bd171908a156
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/archunit-violations/879defc0-4d7e-43cb-ace6-1eb5aec9bac5
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/archunit-violations/c921f20b-c7ee-4fd5-a8e9-c19ac7a59f20
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/archunit-violations/stored.rules (85%)
copy {flink-connector-opensearch => flink-connector-opensearch2}/pom.xml (74%)
create mode 100644
flink-connector-opensearch2/src/main/java/org/apache/flink/connector/opensearch/sink/DefaultBulkResponseInspector.java
copy
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSink.java
=>
flink-connector-opensearch2/src/main/java/org/apache/flink/connector/opensearch/sink/Opensearch2Sink.java
(96%)
copy
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilder.java
=>
flink-connector-opensearch2/src/main/java/org/apache/flink/connector/opensearch/sink/Opensearch2SinkBuilder.java
(86%)
copy
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchWriter.java
=>
flink-connector-opensearch2/src/main/java/org/apache/flink/connector/opensearch/sink/Opensearch2Writer.java
(96%)
copy
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSink.java
=>
flink-connector-opensearch2/src/main/java/org/apache/flink/connector/opensearch/table/Opensearch2DynamicSink.java
(93%)
copy
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkFactory.java
=>
flink-connector-opensearch2/src/main/java/org/apache/flink/connector/opensearch/table/Opensearch2DynamicSinkFactory.java
(98%)
copy
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/OpensearchSinkBuilderSupplier.java
=>
flink-connector-opensearch2/src/main/java/org/apache/flink/connector/opensearch/table/Opensearch2SinkBuilderSupplier.java
(84%)
copy
flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/table/RowOpensearchEmitter.java
=>
flink-connector-opensearch2/src/main/java/org/apache/flink/connector/opensearch/table/RowOpensearch2Emitter.java
(96%)
copy
flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSink.java
=>
flink-connector-opensearch2/src/main/java/org/apache/flink/streaming/connectors/opensearch/Opensearch2Sink.java
(97%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
(91%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/src/test/java/org/apache/flink/architecture/ProductionCodeArchitectureTest.java
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
(100%)
copy
flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/DefaultBulkInspectorTest.java
=>
flink-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch/sink/DefaultBulkResponseInspectorTest.java
(87%)
copy
flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilderTest.java
=>
flink-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch/sink/Opensearch2SinkBuilderTest.java
(51%)
copy
flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkITCase.java
=>
flink-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch/sink/Opensearch2SinkITCase.java
(94%)
copy
flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/OpensearchTestClient.java
=>
flink-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch/sink/Opensearch2TestClient.java
(96%)
copy
flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/OpensearchWriterITCase.java
=>
flink-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch/sink/Opensearch2WriterITCase.java
(91%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/src/test/java/org/apache/flink/connector/opensearch/sink/TestEmitter.java
(98%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/src/test/java/org/apache/flink/connector/opensearch/table/IndexGeneratorTest.java
(100%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/src/test/java/org/apache/flink/connector/opensearch/table/KeyExtractorTest.java
(100%)
copy
flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkFactoryTest.java
=>
flink-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch/table/Opensearch2DynamicSinkFactoryTest.java
(92%)
copy
flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/table/OpensearchDynamicSinkITCase.java
=>
flink-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch/table/Opensearch2DynamicSinkITCase.java
(98%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/src/test/java/org/apache/flink/connector/opensearch/table/TestContext.java
(100%)
copy
flink-connector-opensearch/src/test/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSinkITCase.java
=>
flink-connector-opensearch2/src/test/java/org/apache/flink/streaming/connectors/opensearch/Opensearch2SinkITCase.java
(90%)
copy
flink-connector-opensearch/src/test/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSinkTest.java
=>
flink-connector-opensearch2/src/test/java/org/apache/flink/streaming/connectors/opensearch/Opensearch2SinkTest.java
(90%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/src/test/java/org/apache/flink/streaming/connectors/opensearch/testutils/SourceSinkDataTestKit.java
(99%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/src/test/resources/archunit.properties (97%)
copy {flink-connector-opensearch =>
flink-connector-opensearch2}/src/test/resources/log4j2-test.properties (100%)
copy {flink-sql-connector-opensearch =>
flink-sql-connector-opensearch2}/pom.xml (63%)
create mode 100644
flink-sql-connector-opensearch2/src/main/resources/META-INF/NOTICE
copy
{flink-sql-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch
=>
flink-sql-connector-opensearch2/src/test/java/org/apache/flink/connector/opensearch2}/PackagingITCase.java
(92%)
