Search code examples
elasticsearchapache-flinkxpack

Flink Xpack ElasticSearch 5 ElasticsearchSecurityException missing autentication

Goodmorning everyone. I am trying to Flink connector Elasticsearch 5.2.1 and I have problems with the authentication XPACK

Solution

  • Using a different transport clients is currently (March 2017, Flink 1.2) not supported in Flink.

    However, I've filed a JIRA to add the feature: FLINK-6065 Make TransportClient for ES5 pluggable

    Until this has been implemented into Flink, I recommend overriding the ElasticsearchSink and using a different call bridge calling the PreBuiltXPackTransportClient.