ElasticSearch Spark Error

Question

私はElasticSearchを初めて使用しています。私はElasticSearchにいくつかのデータを保存するためにApache Sparkコードを書こうとしています。私はSparkShellに次の行を入力しました：

import org.elasticsearch.spark._ 
val myMap = Map("France" -> "FRA", "United States" -> "US") 
val myRDD = sc.makeRDD(Seq(myMap)) 
myRDD.saveToEs("Country/Abbrv") 

エラー：

org.elasticsearch.hadoop.EsHadoopIlegalArgumentException: Cannot determine write shards for [Country/Abbrv]; likely its format is incorrect (maybe it contains illegal characters?) 

スパーク2.0.0 ElasticSearch-スパーク2.3.4

任意のアイデア？

Answer 1

問題は、sparkシェルを起動する前に--conf varを設定しなかったことです。次のようにする必要があります。

spark-shell --jars {path}/elasticsearch-spark_2.11-2.3.4.jar --conf spark.es.resource=Country/Abbrv