flink-connector-elasticsearch
flink-connector-elasticsearch copied to clipboard
apache
Apache Flink connector for ElasticSearch
https://issues.apache.org/jira/browse/FLINK-34369 #### 02/05/2024 This is a preliminary PR that was tested locally with secure ES clusters. Plan is to get early feedback, add some tests, and test with deployed jobs.
[](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting `@dependabot rebase`....
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
According to [FLIP-127](https://cwiki.apache.org/confluence/display/FLINK/FLIP-127%3A+Support+Elasticsearch+Source+Connector) to achieve source read function
## What is the purpose of the change The example in the Elasticsearch doc of the fault tolerance section is missing. Chinese translations of the fault tolerance section are missing.
Delete id(key) in the RowElasticsearchEmitter class the key is always null, this makes users get confused.
https://issues.apache.org/jira/browse/FLINK-35287 > In [FLINK-26088](https://issues.apache.org/jira/browse/FLINK-26088) we added support for ElasticSearch 8.0. It is based on Async sink API and does not use the base module flink-connector-elasticsearch-base. Regarding the config options (host,...
Bumps [org.elasticsearch:elasticsearch](https://github.com/elastic/elasticsearch) from 7.10.2 to 7.17.23. Release notes Sourced from org.elasticsearch:elasticsearch's releases. Elasticsearch 7.17.23 Downloads: https://elastic.co/downloads/elasticsearch Release notes: https://www.elastic.co/guide/en/elasticsearch/reference/7.17/release-notes-7.17.23.html Elasticsearch 7.17.22 Downloads: https://elastic.co/downloads/elasticsearch Release notes: https://www.elastic.co/guide/en/elasticsearch/reference/7.17/release-notes-7.17.22.html Elasticsearch 7.17.21 Downloads: https://elastic.co/downloads/elasticsearch...
https://issues.apache.org/jira/browse/FLINK-35472 > Per discussion in [this PR](https://github.com/apache/flink-connector-elasticsearch/pull/104) (thanks to @reta), it makes the tests more reusable if we use parameterized tests. It requires some changes of the existing tests, which...
JIRA: https://issues.apache.org/jira/browse/FLINK-35546 Discussion in mailing list: https://lists.apache.org/thread/yrf0mmbch0lhk3rgkz94fr0x5qz2417l