问题是我没有在启动spark shell之前设置–conf var。它需要如下所示:
spark-shell --jars {path}/elasticsearch-spark_2.11-2.3.4.jar --conf spark.es.resource=Country/Abbrv
问题是我没有在启动spark shell之前设置–conf var。它需要如下所示:
spark-shell --jars {path}/elasticsearch-spark_2.11-2.3.4.jar --conf spark.es.resource=Country/Abbrv