Error in adding Nested objects using Spark on Es-Index

Elastic Stack Elasticsearch
1

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
{
"note":
{
"a":"1",
"b':"2"
}
}

//Es properties used:
.option("es.mapping.id", "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

2

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