弹性搜索与火花

Question

我正在尝试使用elasticsearch-spark库和sbt工件："org.elasticsearch" %% "elasticsearch-spark" % "2.3.2"来设置search和Eleastic。当我尝试用以下代码配置优化搜索时：

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")
       

对于上面所有的set语句，我总是得到一个错误：illegal character，用于弹性搜索。有人知道这个问题吗？

Answer 1

您必须从任何网站或任何其他博客复制代码。它包含无法读懂的字符，实际上给你带来了麻烦。

简单解决方案:删除所有内容。一个一个地手动输入，然后运行它。如果你再遇到任何问题，我会帮你的。

Answer 2

您可能希望将http.publish_host设置为elasticsearch.yml中的HOST_NAME。es-hadoop连接器正在从_node/transport中嗅探节点，因此它检查已发布的http地址是什么。