# ScalaMapFieldExtractor Cannot extract value from entity

**URL:** <https://discuss.elastic.co/t/scalamapfieldextractor-cannot-extract-value-from-entity/88530>\
**Category:** Elasticsearch\
**Tags:** es-hadoop\
**Created:** [June 7, 2017, 8:19am UTC](https://discuss.elastic.co/t/scalamapfieldextractor-cannot-extract-value-from-entity/88530 "2017-06-07T08:19:51Z")\
**Posts on this page:** 1\
**Showing post:** 2

<div class="post-metadata">

**Author:** ![simonlucalandi](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/simonlucalandi/32/14990_2.png) [@simonlucalandi](https://discuss.elastic.co/u/simonlucalandi)\
**Post date:** [June 7, 2017, 12:21pm UTC](https://discuss.elastic.co/t/scalamapfieldextractor-cannot-extract-value-from-entity/88530/2 "2017-06-07T12:21:31Z")

</div>

It seams that the solution is to use and additional map stage, as suggested in [https://discuss.elastic.co/t/cannot-extract-value-from-entity/66556](https://discuss.elastic.co/t/cannot-extract-value-from-entity/66556)

> rdd.map({case Some(subscriptionInfo) =\> subscriptionInfo}).saveToEs("spark/docs", Map("es.mapping.id" -\> "sub\_id"))

---

_[View the full topic](https://discuss.elastic.co/t/scalamapfieldextractor-cannot-extract-value-from-entity/88530)._