Flink Xpack ElasticSearch 5 ElasticsearchSecurityException autenticationがありません

おはようございます。私はFlinkコネクタElasticsearch 5.2.1を試行しており、認証XPACKに問題がありますFlink Xpack ElasticSearch 5 ElasticsearchSecurityException autenticationがありません

出典

2017-03-15 Eragorn87

直面している問題の詳細を追加できますか？ –

こんにちは、私はElasticsearchに接続したいのですが、私はコネクタを使用しています。Flink 'code config.put（" cluster.name "、" my-application "）; config.put（ "bulk.flush.max.actions"、 "1"）; List transportAddresses = new ArrayList <>（）;transportAddresses.add（新しいInetSocketAddress（InetAddress.getByName（ "localhost"）、9300））; input.addSink（新しいElasticsearchSink <>（config、transportAddresses、new ElasticsearchFlink（）））; ' 私はXPackをインストールしましたが、接続しようとするとこのエラーが発生します： ' code原因：ElasticsearchSecurityException [アクションの認証トークンが見つかりませんでした。] – Eragorn87

/org/apache/flink/streaming/connectors/elasticsearch5/Elasticsearch5ApiCallBridgeで見ました。 Javaクラスが使用されています_New PreBuiltTransportClient（settings）; _Newの代わりに_ PreBuiltXPackTransportClient（設定）_ – Eragorn87

Flinkでサポートされていない別のトランスポートクライアント（2017年3月、Flink 1.2）を使用しています。

はしかし、私は機能を追加するためにJIRAを提出しました：これはFLINKに実装されるまでFLINK-6065 Make TransportClient for ES5 pluggable

、私はElasticsearchSinkをオーバーライドしてPreBuiltXPackTransportClientを呼び出して別の通話ブリッジを使用することをお勧めします。

出典

2017-03-15 17:50:24

ありがとう、私は解決しました！ – Eragorn87

Flink Xpack ElasticSearch 5 ElasticsearchSecurityException autenticationがありません

答えて

関連する問題