1
Goodmorning alle. Ich versuche den Connector Elasticsearch 5.2.1 zu flackern und habe Probleme mit der Authentifizierung XPACKFlink Xpack ElasticSearch 5 ElasticsearchSecurityException fehlende Authentifizierung
A
Antwort
0
Die Verwendung eines anderen Transportclients wird derzeit (März 2017, Flink 1.2) in Flink nicht unterstützt.
Allerdings habe ich eine JIRA reichte die Funktion hinzuzufügen: FLINK-6065 Make TransportClient for ES5 pluggable
Bis diese in Flink umgesetzt wurde, empfehle ich das Überschreiben der ElasticsearchSink und eine andere Anrufbrücke die PreBuiltXPackTransportClient Aufruf verwenden.
+0
Vielen Dank, ich habe gelöst! – Eragorn87
Verwandte Themen
- 1. Fink mit ElasticSearch 5 Sink Konflikte der io.nety Bibliothek
- 2. Flink Paket fehlende Klasse CheckpointCommitter - flink-connector-cassandra - schwerer Fehler
- 3. Fehlende ASP.NET 5 Vorlagen
- 4. Authentifizierung in Elasticsearch
- 5. Logstash und Elasticsearch fehlende Daten
- 6. Es ist möglich, ein Elasticsearch 5.x mit Flink 1.2.0 zu starten?
- 7. Jhipster fehlende Authentifizierung Inhaber Token
- 8. fehlende Authentifizierung oder ungültige Anmeldung
- 9. HTTP-Statuscode für fehlende Authentifizierung
- 10. AngularJS + Laravel 5 Authentifizierung
- 11. Fehlende ViewController.xib in Xcode 5
- 12. Laravel 5: Fehlende Argument-Controller
- 13. Elasticsearch 5: MapperParserException mit multi_field
- 14. Mit PreBuiltTransportClient mit Elasticsearch 5
- 15. Elasticsearch 5: Boost-1-Feld
- 16. ASP.NET MVC 5: Benutzerdefinierte Authentifizierung
- 17. Authentifizierung in ASP.NET 5 (vNext)
- 18. Flink-elastische Suchartefakt-ID fehlt?
- 19. Unterschied zwischen elasticsearch 2.x und elasticsearch 5.x?
- 20. ECMAScript 5 - Fehler Fehlende Klasseneigenschaften transformieren
- 21. Rails 5 fehlende Vorlage, die hinzugefügt wurde
- 22. Fehlende android manifest unity 5 mopub integration
- 23. elasticsearch Authentifizierung mit Java API Client
- 24. Neuinstallation von ElasticSearch 5.0.2 erfordert Authentifizierung - warum?
- 25. Nach der Installation von xpack auf Kibana 5.0 kann die App nicht geladen werden
- 26. Wie benutze ich Elasticsearch 5.x mit Nutch/Wie indexiere ich HTML-Webseiten in Elasticsearch 5?
- 27. Elasticsearch 5 stoppt während langer Indizierung
- 28. Unterstützt Spring Data Elasticsearch 5.x?
- 29. Elasticsearch Upgrade von 1 bis 5 - SearchRequestBuilder.setNoFields
- 30. Elasticsearch - Implementierungsabschlussvorschlag in Java (API Version 5!)
Können Sie weitere Details zu den Problemen hinzufügen, denen Sie gegenüberstehen? –
Hallo, ich möchte eine Verbindung zu Elasticsearch herstellen und verwende den Connector Flink 'code config.put (" cluster.name "," my-application "); config.put ("bulk.flush.max.actions", "1"); Liste transportAddresses = new ArrayList <>(); transportAddresses.add (neue InetSocketAddress (InetAddress.getByName ("localhost"), 9300)); input.addSink (new ElasticsearchSink <> (config, transportAdressen, new ElasticsearchFlink())); ' Ich installiert XPack und wenn ich versuche, eine Verbindung gibt mir diesen Fehler: ' Code verursacht durch: ElasticsearchSecurityException [fehlende Authentifizierung Token für die Aktion ' –
Eragorn87
Ich sah, dass in/org/apache/flink/Streaming/Anschlüsse/elasticsearch5/Elasticsearch5ApiCallBridge. Java-Klasse wird verwendet _new PreBuiltTransportClient (Einstellungen); _ statt _new PreBuiltXPackTransportClient (Einstellungen) _ – Eragorn87