2016-07-07 6 views
0

elasticsearch-sparkライブラリと"org.elasticsearch" %% "elasticsearch-spark" % "2.3.2"のライブラリを使用してスパークとエレガント検索を設定しようとしています。私はこのコードでeleastic検索を設定しようとすると:弾性検索のための上記セット文のすべてのためのillegal character弾性検索とスパーク

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

を私はエラーを取得しておきます。誰でも問題を知っていますか?

答えて

2

ウェブサイトや他のブログからコードをコピーしてください。それは実際にあなたに困っている読めない文字を含んでいます。

単純な解決策:すべてのコンテンツを削除します。手動で1つずつ入力して実行してください。問題が発生した場合は、お手伝いします。

+0

それが問題でした。私はそれをウェブサイトからコピーして、違法な文字を入れてしまい、IntelliJ IDEがそれを読むことができませんでした。私はちょうどすべてのテキストを削除し、それを再入力し、それは働いた。ありがとう! – CapturedTree

+0

スパークから弾性検索にデータを保存する際に問題が発生した場合、私を助けることができると思いますか? – CapturedTree

+1

確かに...あなたの問題を教えてください...私はあなたを助けようとします。 – Srini

0

あなたのelasticsearch.ymlのhttp.publish_hostをHOST_NAMEに設定するとよいでしょう。 es-hadoopコネクタは_nodes/transport APIからノードを傍受し、公開されたhttpアドレスが何であるかを確認します。