Flink Xpack ElasticSearch 5 ElasticsearchSecurityException отсутствует проверка подлинности

Доброе утро всем. Я пытаюсь Flink разъем Elasticsearch 5.2.1 и у меня проблемы с проверкой подлинности XPACK

Источник

1 ответ

Решение

Использование других транспортных клиентов в настоящее время (март 2017 г., Flink 1.2) не поддерживается в Flink.

Тем не менее, я подал JIRA, чтобы добавить функцию: FLINK-6065 Сделать TransportClient для ES5 подключаемым

Пока это не реализовано во Flink, я рекомендую переопределить ElasticsearchSink и используя другой мост вызова, вызывающий PreBuiltXPackTransportClient,

Источник
Другие вопросы по тегам