SqlContext 错误？

Posted 2023-04-18

【中文标题】SqlContext 错误？

【英文标题】：SqlContext Error?

【发布时间】：2018-07-23 11:20:50

【问题描述】：

我正在尝试将 json 文件保存到 Elasticsearch。 我收到此错误

线程“主”java.lang.AbstractMethodError 中的异常

我正在使用“spark 2.3.0”和“scala 2.11.6” 请在下面找到代码：

import org.apache.spark.sql.SQLContext
import org.elasticsearch.spark.sql._

import org.apache.spark.SparkConf, SparkContext

object OrangetoES 

  def main(args: Array[String]) 
    val conf = new SparkConf().setAppName("OrangetoES").setMaster("local[*]")
    val sc = new SparkContext(conf)
    conf.set("es.index.auto.create", "true")
    val sqlc = new SQLContext(sc)
    val df = sqlc.read.json("../Orange.json")
    df.saveToEs("orangetoes/people")
  

我该如何解决这个问题？

【参考方案1】：

只是我必须将 ES-Hadoop 版本从 13 修改为 20