Re: [PR] [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15 [inlong]

2024-08-02 Thread via GitHub
EMsnap merged PR #10740: URL: https://github.com/apache/inlong/pull/10740 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong.apa

Re: [PR] [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15 [inlong]

2024-08-01 Thread via GitHub
XiaoYou201 commented on code in PR #10740: URL: https://github.com/apache/inlong/pull/10740#discussion_r1701137494 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/pom.xml: ## @@ -0,0 +1,140 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="htt

Re: [PR] [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15 [inlong]

2024-08-01 Thread via GitHub
XiaoYou201 commented on code in PR #10740: URL: https://github.com/apache/inlong/pull/10740#discussion_r1701126963 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/RowElasticsearchSinkFunction.java: ##

Re: [PR] [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15 [inlong]

2024-08-01 Thread via GitHub
XiaoYou201 commented on code in PR #10740: URL: https://github.com/apache/inlong/pull/10740#discussion_r1701126872 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/ElasticsearchConfiguration.java:

Re: [PR] [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15 [inlong]

2024-08-01 Thread via GitHub
aloyszhang commented on code in PR #10740: URL: https://github.com/apache/inlong/pull/10740#discussion_r1701122567 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/RowElasticsearchSinkFunction.java: ##

Re: [PR] [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15 [inlong]

2024-08-01 Thread via GitHub
aloyszhang commented on code in PR #10740: URL: https://github.com/apache/inlong/pull/10740#discussion_r1701120391 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/KeyExtractor.java: ## @@ -0,0

Re: [PR] [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15 [inlong]

2024-08-01 Thread via GitHub
aloyszhang commented on code in PR #10740: URL: https://github.com/apache/inlong/pull/10740#discussion_r1701120129 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/IndexGeneratorFactory.java: #

Re: [PR] [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15 [inlong]

2024-08-01 Thread via GitHub
aloyszhang commented on code in PR #10740: URL: https://github.com/apache/inlong/pull/10740#discussion_r1701119130 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/ElasticsearchValidationUtils.java: ##

Re: [PR] [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15 [inlong]

2024-08-01 Thread via GitHub
aloyszhang commented on code in PR #10740: URL: https://github.com/apache/inlong/pull/10740#discussion_r1701118602 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/ElasticsearchConfiguration.java:

Re: [PR] [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15 [inlong]

2024-08-01 Thread via GitHub
aloyszhang commented on code in PR #10740: URL: https://github.com/apache/inlong/pull/10740#discussion_r1701116725 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/pom.xml: ## @@ -0,0 +1,140 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="htt

[PR] [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15. [inlong]

2024-07-31 Thread via GitHub
XiaoYou201 opened a new pull request, #10740: URL: https://github.com/apache/inlong/pull/10740 ### [INLONG-10739][Sort] Add Elasticsearch connector base on flink1.15. Fixes #10739 ### Motivation Add the elasticsearch-base module to implement elasticsearch connector 6&7