1
굿모닝 여러분. Flink 커넥터 Elasticsearch 5.2.1을 시도하고 인증 XPACK에 문제가 있습니다.Flink Xpack ElasticSearch 5 ElasticsearchSecurityException이 누락되었습니다.
A
답변
0
Flink에서 지원되지 않는 다른 전송 클라이언트 (2017 년 3 월, Flink 1.2)를 사용 중입니다.
그러나, 나는이 기능을 추가 할 JIRA을 제기했습니다이 FLINK로 구현 될 때까지 FLINK-6065 Make TransportClient for ES5 pluggable
을, 나는 ElasticsearchSink을 무시하고 PreBuiltXPackTransportClient를 호출하는 다른 콜 서비스를 사용하는 것이 좋습니다.
+0
정말 고맙습니다. 해결되었습니다! – Eragorn87
직면하고있는 문제에 대해 더 자세히 설명해 주시겠습니까? –
안녕하세요, Elasticsearch에 연결하고 커넥터를 사용하고 있습니다. Flink 'code config.put ("cluster.name", "my-application"); config.put ("bulk.flush.max.actions", "1"); 목록 transportAddresses = 새 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에서이를 보았습니다. 자바 클래스가 사용되었습니다. _New PreBuiltTransportClient (settings); _ 대신 새로운 _ PreBuiltXPackTransportClient (설정) _ – Eragorn87