Apache Flink 1.17 Elasticsearch Connector - Цифровое Кемерово

Apache Flink 1.17 Elasticsearch Connector ⇐ JAVA

1 сообщение • Страница 1 из 1

Anonymous

Apache Flink 1.17 Elasticsearch Connector

Цитата

Сообщение Anonymous » 28 янв 2025, 17:56

Мы обновляем Apache Flink с версии 1.16 до 1.17. В нашем проекте у нас уже есть ElasticSearch7 Connector.
Согласно этому https://mvnrepository.com/artifact/org. ... ticsearch7, нам нужно использовать Версия 3.0.1-1.17 И это место, где начинается проблема. дольше доступно. Я обнаружил, что ElasticSearchSinkBuilderBase в качестве потенциального класса для создания раковины, но я ничего не могу найти в том, как его использовать. Elastic in Flink 1.17+?

Подробнее здесь: https://stackoverflow.com/questions/793 ... -connector

1738076190

Anonymous

 Мы обновляем Apache Flink с версии 1.16 до 1.17. В нашем проекте у нас уже есть ElasticSearch7 Connector. 
Согласно этому https://mvnrepository.com/artifact/org.apache.flink/flink-connector-elasticsearch7, нам нужно использовать Версия 3.0.1-1.17 И это место, где начинается проблема. дольше доступно. Я обнаружил, что ElasticSearchSinkBuilderBase  в качестве потенциального класса для создания раковины, но я ничего не могу найти в том, как его использовать. Elastic in Flink 1.17+?  

Подробнее здесь: [url]https://stackoverflow.com/questions/79394249/apache-flink-1-17-elasticsearch-connector[/url]

Ответить

1 сообщение • Страница 1 из 1