Using the following dependency for Spark 3 in POM file (My Scala version is
2.12.14)
*org.elasticsearch
elasticsearch-spark-30_2.12
7.12.0provided*
The code throws error at this line :
df.write.format("es").mode("overwrite").options(elasticOptions).save("index_name")
The same code
What’s the version of the ES connector you are using?
On Sat, Aug 26, 2023 at 10:17 AM Dipayan Dev
wrote:
> Hi All,
>
> We're using Spark 2.4.x to write dataframe into the Elasticsearch index.
> As we're upgrading to Spark 3.3.0, it throwing out error
> Caused by:
