Error in adding Nested objects using Spark on Es-Index

Caused by: java.lang.ClassCastException: org.apache.spark.sql.catalyst.expressions.GenericRowWithSchema cannot be cast to scala.Tuple2

Details: Es version-6.3
Incoming object example

//Es properties used:
.option("", "note.a")
.option("es.write.operation", "upsert")
.option(ConfigurationOptions.ES_UPDATE_SCRIPT_INLINE, "ctx._source.notefield.add(params.param1)")
.option(ConfigurationOptions.ES_UPDATE_SCRIPT_PARAMS, "param1:note")
.option("es.write.operation", "upsert")

//the "notefield" is declared as nested in mapping at ES.
Any suggestions

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.