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%)