spark 读es数据时报Cannot find mapping for 014/_search - one is required before using Spark SQL

这个错误通常是因为 Spark SQL 无法正确地推断 Elasticsearch 索引的模式，因此无法将它映射到 Spark SQL 表中。解决这个问题的方法是明确指定 Elasticsearch 索引的模式。

在使用 Spark 读取 Elasticsearch 数据时，您可以通过以下方式指定索引模式：

import org.apache.spark.sql.types._

val schema = StructType(Array(
  StructField("field1", StringType),
  StructField("field2", IntegerType),
  StructField("field3", DoubleType)
))

val df = spark.read.format("org.elasticsearch.spark.sql")
  .option("es.nodes", "localhost")
  .option("es.port", "9200")
  .option("es.index.read.missing.as.empty", "true")
  .option("es.nodes.wan.only", "true")
  .option("es.mapping.date.rich", "false")
  .option("es.read.field.as.array.include", "field4")
  .schema(schema)
  .load("index_name/type_name")

在上面的示例中，我们首先显式地定义了 Elasticsearch 索引中的字段模式。然后，我们在读取 Elasticsearch 数据时将这个模式传递给 Spark SQL，这样 Spark SQL 就能正确地将数据映射到表中。

请注意，这里的索引名和类型名应该是 Elasticsearch 中实际使用的名称，并且您需要替换正确的主机和端口。另外，这里的其他选项也可以根据需要进行调整。