Elastische Suche und Spark

Question

Ich versuche, Funken und eleastische Suche unter Verwendung der elasticsearch-spark-Bibliothek mit dem sbt-Artefakt einzurichten: "org.elasticsearch" %% "elasticsearch-spark" % "2.3.2". Wenn ich versuche, eleastic Suche mit diesem Code zu konfigurieren:

val sparkConf = new SparkConf().setAppName("test").setMaster("local[2]") 
.set("es.index.auto.create", "true")
  
.set("es.resource", "test") 
.set("es.nodes", "test.com:9200")
  

halte ich den Fehler bekommen: illegal character für alle gesetzten Aussagen über für Elasticsearch. Wer kennt das Problem?

Answer 1

Sie müssen den Code von einer Website oder einem anderen Blog kopiert haben. Es enthält unlesbare Zeichen, die Ihnen Probleme bereiten.

Einfache Lösung: Löschen Sie den gesamten Inhalt. Geben Sie eins nach dem anderen manuell ein und führen Sie es aus. Lassen Sie mich wissen, wenn Sie wieder Probleme haben, werde ich Ihnen helfen.

Answer 2

Sie können den http.publish_host in Ihrer elasticsearch.yml auf HOST_NAME festlegen. Der Es-Hadoop-Connector schnüffelt die Knoten aus der _nodes/transport-API, um zu prüfen, wie die veröffentlichte http-Adresse lautet.