# How can I save a data with type Array\[String\] to Es with painless script
**URL:** https://discuss.elastic.co/t/how-can-i-save-a-data-with-type-array-string-to-es-with-painless-script/182584
**Category:** Elasticsearch
**Created:** [May 24, 2019, 8:03am UTC](https://discuss.elastic.co/t/how-can-i-save-a-data-with-type-array-string-to-es-with-painless-script/182584 "2019-05-24T08:03:45Z")
**Posts on this page:** 3
**Page:** 1
### Author:  [@huolongguo007](https://discuss.elastic.co/u/huolongguo007)
#### Post date: [May 24, 2019, 8:03am UTC](https://discuss.elastic.co/t/how-can-i-save-a-data-with-type-array-string-to-es-with-painless-script/182584/1 "2019-05-24T08:03:45Z")
**In my project, i tried to save the data from spark-stream to ES, to be exact, it is to update a struct table. I don't known is there any better way to update data in ES? Well, I used the painless script to update, like this:**
```
def fooUpdate(dfNewData: DataFrame): Unit = {
val upParams = "ports:port_list, type:asset_type, reqCnt:request_connect_count,
rsvCnt:receive_connect_count, timestamp:discover_time"
val upScript = "int flag = 0;if((null != params.ports) && (0 != params.ports.length))......"
val esWriteConf = Map("es.write.operation" -> "upsert",
"es.mapping.id" -> "ip_addr",
"es.update.script.lang" -> "painless",
"es.update.script.params" -> upParams,
"es.update.script.inline" -> upScript
)
dfNewData.saveToEs("spark/netAsset", esWriteConf) //execute error from here
}
```
**The table schema is:**
root
|-- mac\_addr: string (nullable = false)
|-- ip\_addr: string (nullable = false)
|-- port\_list: array (nullable = false)
| |-- element: string (containsNull = true)
|-- asset\_type: string (nullable = false)
|-- request\_connect\_count: long (nullable = false)
|-- receive\_connect\_count: long (nullable = false)
|-- discover\_time: timestamp (nullable = false)
|-- ports\_offline: array (nullable = false)
| |-- element: string (containsNull = true)
|-- ports\_online\_new: array (nullable = false)
| |-- element: string (containsNull = true)
|-- last\_change\_time: timestamp (nullable = false)
**The main error message is:**
_org.elasticsearch.hadoop.serialization.EsHadoopSerializationException: java.lang.ClassCastException: scala.collection.mutable.WrappedArray$ofRef cannot be cast to scala.Tuple2_
**I tried many time to find the reason, the problem maybe caused by the data type of Array[String], As the code shows, if i deleted the params of "ports:port\_list"οΌthe code runs well. and if i change the data type of the column "port\_list" to String, it also runs OKγ**
**I can't find any example of the complex data type save to ES, and a more detailed config description of "es.update.script.params". So it's the problem of my code or a bugs of ES or something else... Anyone Helps, Thanks very much!!!**
**my project environment:**
-
```
elasticsearch 6.6.1
```
-
```
elasticsearch-spark-20
```
-
```
scala 2.11.7
```
-
```
spark 2.4.1
```
-
```
spark-streaming-kafka-0-10
```
---
### Author:  [@huolongguo007](https://discuss.elastic.co/u/huolongguo007)
#### Post date: [May 27, 2019, 3:36am UTC](https://discuss.elastic.co/t/how-can-i-save-a-data-with-type-array-string-to-es-with-painless-script/182584/2 "2019-05-27T03:36:24Z")
ππππ mark :
19/05/27 11:28:44 WARN TaskSetManager: Lost task 3.0 in stage 36.0 (TID 2015, 10.8.70.14, executor 0): org.elasticsearch.hadoop.serialization.EsHadoopSerializationException: java.lang.ClassCastException: scala.collection.mutable.WrappedArray$ofRef cannot be cast to scala.Tuple2
at org.elasticsearch.hadoop.serialization.bulk.BulkEntryWriter.writeBulkEntry(BulkEntryWriter.java:136)
at org.elasticsearch.hadoop.rest.RestRepository.writeToIndex(RestRepository.java:170)
at org.elasticsearch.spark.rdd.EsRDDWriter.write(EsRDDWriter.scala:71)
at org.elasticsearch.spark.sql.EsSparkSQL$$anonfun$saveToEs$1.apply(EsSparkSQL.scala:101)
at org.elasticsearch.spark.sql.EsSparkSQL$$anonfun$saveToEs$1.apply(EsSparkSQL.scala:101)
at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:90)
at org.apache.spark.scheduler.Task.run(Task.scala:121)
at org.apache.spark.executor.Executor$TaskRunner$$anonfun$10.apply(Executor.scala:403)
at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:409)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassCastException: scala.collection.mutable.WrappedArray$ofRef cannot be cast to scala.Tuple2
at org.elasticsearch.spark.sql.DataFrameValueWriter.write(DataFrameValueWriter.scala:53)
at org.elasticsearch.hadoop.serialization.bulk.AbstractBulkFactory$FieldWriter.doWrite(AbstractBulkFactory.java:152)
at org.elasticsearch.hadoop.serialization.bulk.AbstractBulkFactory$FieldWriter.write(AbstractBulkFactory.java:118)
at org.elasticsearch.hadoop.serialization.bulk.TemplatedBulk.writeTemplate(TemplatedBulk.java:80)
at org.elasticsearch.hadoop.serialization.bulk.TemplatedBulk.write(TemplatedBulk.java:56)
at org.elasticsearch.hadoop.serialization.bulk.BulkEntryWriter.writeBulkEntry(BulkEntryWriter.java:68)
---
### Author:  [@system](https://discuss.elastic.co/u/system)
#### Post date: [June 24, 2019, 3:37am UTC](https://discuss.elastic.co/t/how-can-i-save-a-data-with-type-array-string-to-es-with-painless-script/182584/3 "2019-06-24T03:37:31Z")
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.