Java entity not mapping to ElasticSearch GeoPoint property

I have created a minimal application with a repository, a controller and am running this with Spring Boot 2.1.3.RELEASE, Spring Data Elasticsearch 3.1.5.RELEASE, elasticsearch client 6.4.3 and an Elasticsearch server 6.4.0.

I am using a Person pojo class that has two geo_point fields, one is a normal spring GeoPoint and one a custom MyGeoPoint that uses the GeoPointFieldannotation.

After starting the application and inserting a record by calling the RestController's init method, the mapping in the index are alright:

{
  "person": {
    "aliases": {},
    "mappings": {
      "person": {
        "properties": {
          "firstName": {
            "type": "text",
            "fields": {
              "keyword": {
                "type": "keyword",
                "ignore_above": 256
              }
            }
          },
          "geoPoint": {
            "type": "geo_point"
          },
          "id": {
            "type": "long"
          },
          "lastName": {
            "type": "text",
            "fields": {
              "keyword": {
                "type": "keyword",
                "ignore_above": 256
              }
            }
          },
          "myGeoPoint": {
            "type": "geo_point"
          }
        }
      }
    },
    "settings": {
      "index": {
        "refresh_interval": "1s",
        "number_of_shards": "5",
        "provided_name": "person",
        "creation_date": "1554750620775",
        "store": {
          "type": "fs"
        },
        "number_of_replicas": "1",
        "uuid": "w1L279wOQUmvDPMu4iYXtg",
        "version": {
          "created": "6040099"
        }
      }
    }
  }
}

Person.java

/*
 * (c) Copyright 2019 sothawo
 */
package com.sothawo.springdataelastictest;

import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.GeoPointField;
import org.springframework.data.elasticsearch.core.geo.GeoPoint;

/**
 * @author P.J. Meisch ([email protected])
 */
@Document(indexName = "person", type = "person")
public class Person {
    @Id private Long id;
    private String lastName;
    private String firstName;

    private GeoPoint geoPoint;

    @GeoPointField private MyGeoPoint myGeoPoint;

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getLastName() {
        return lastName;
    }

    public void setLastName(String lastName) {
        this.lastName = lastName;
    }

    public String getFirstName() {
        return firstName;
    }

    public void setFirstName(String firstName) {
        this.firstName = firstName;
    }

    public GeoPoint getGeoPoint() {
        return geoPoint;
    }

    public void setGeoPoint(GeoPoint geoPoint) {
        this.geoPoint = geoPoint;
    }

    public MyGeoPoint getMyGeoPoint() {
        return myGeoPoint;
    }

    public void setMyGeoPoint(MyGeoPoint myGeoPoint) {
        this.myGeoPoint = myGeoPoint;
    }

    @Override
    public String toString() {
        return "Person{" +
                "id=" + id +
                ", lastName='" + lastName + '\'' +
                ", firstName='" + firstName + '\'' +
                ", geoPoint=" + geoPoint +
                ", myGeoPoint=" + myGeoPoint +
                '}';
    }

    public static class MyGeoPoint {
        private double lat;
        private double lon;

        public double getLat() {
            return lat;
        }

        public void setLat(double lat) {
            this.lat = lat;
        }

        public double getLon() {
            return lon;
        }

        public void setLon(double lon) {
            this.lon = lon;
        }

        @Override
        public String toString() {
            return "MyGeoPoint{" + "lat=" + lat + ", lon=" + lon + '}';
        }
    }
}

PersonRepository.java:

package com.sothawo.springdataelastictest;

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

public interface PersonRepository extends ElasticsearchRepository<Person, Long> {}

ElasticsearchRepositoryController.java:

package com.sothawo.springdataelastictest;

import org.springframework.data.elasticsearch.core.geo.GeoPoint;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/repo")
public class ElasticsearchRepositoryController {

    private PersonRepository personRepository;

    public ElasticsearchRepositoryController(PersonRepository personRepository) {
        this.personRepository = personRepository;
    }

    @GetMapping("/init")
    public Long initPerson() {
        final Person person = new Person();
        person.setId(42L);
        person.setFirstName("John");
        person.setLastName("Doe");

        GeoPoint geoPoint = new GeoPoint(12.34, 56.78);
        person.setGeoPoint(geoPoint);

        Person.MyGeoPoint myGeoPoint = new Person.MyGeoPoint();
        myGeoPoint.setLat(43.21);
        myGeoPoint.setLon(87.65);
        person.setMyGeoPoint(myGeoPoint);

        return personRepository.save(person).getId();

    }
}

SpringdataElasticTestApplication.java:

package com.sothawo.springdataelastictest;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;

@SpringBootApplication
@EnableElasticsearchRepositories
public class SpringdataElasticTestApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringdataElasticTestApplication.class, args);
    }
}

So I cannot find a problem with this code and the versions I used. Can you reproduce the error with these classes or build a minimal example that reproduces the error?

Are you sure, that the mapping is created by the Repository class and not somewhere else?

And can you please check the mapping after the application is started, but before any data is inserted into the index?

I had the same issue, after I deleted an Index during the runtime of the application (spring-boot 2.2.1.RELEASE with spring-data-elasticserach 4.0.0.DATAES-690-SNAPSHOT).

After I saved a document, the index hat the wrong mapping for the location property:

... other properites...

"location" : {
  "properties" : {
    "lat" : {
      "type" : "float"
    },
    "lon" : {
      "type" : "float"
    }
  }
}

I could not solve it during the runtime of the application, the mapping was always wrong.

This solution worked for me:

1. delete the index
2. restart the application

Now the index was created with JUST the location field, all other field-mappings missing. After indexing documents (with ElasticSearchRepository.save), everything was fine, the other mappings where added.

{
    "properties": {
        "location": {
            "type": "geo_point"
        }
    }
}

I had a similar problem but I solved it this way: On the ES side, create the index like this:

PUT my_index
{
  "mappings": {
    "properties": {
      "doc.location": {
        "type": "geo_point"
      }
    }
  }
}

In location is the field that I want to be geo_point type. Excuse my English. Of course, ES must follow the following structure for its persistence:

"location": { 
    "lat": 41.12,
    "lon": -71.34
}

You said it here.

I had a similar problem but after some documentation surfing I had to use the following code snippet to get the Elasticsearch to create my GeoPoint property as a geo_point typed field.

@Autowired
private ElasticsearchRestTemplate elasticsearchRestTemplate;

@PostConstruct
public void init() {
    IndexOperations indexOperations = elasticsearchRestTemplate.indexOps(PropertySearch.class);
    indexOperations.putMapping(indexOperations.createMapping());
    indexOperations.refresh();
}

For more information you can refer post

if (elasticsearchRestTemplate.indexOps(MerchantModel.class).exists()) {
    elasticsearchRestTemplate.indexOps(MerchantModel.class).delete();
}
// fix geo_point mapping
CreateIndexRequest createIndexRequest = new CreateIndexRequest("merchant");
createIndexRequest.mapping("{\n" +
        "      \"properties\": {\n" +
        "        \"location\": {\n" +
        "          \"type\": \"geo_point\"\n" +
        "        }\n" +
        "      }\n" +
        "    }", XContentType.JSON);
IndicesClient indicesClient = restHighLevelClient.indices();
CreateIndexResponse createIndexResponse = indicesClient.create(createIndexRequest, RequestOptions.DEFAULT);
log.info("create ES merchant mapping:[isAcknowledged={}]", createIndexResponse.isAcknowledged());