diff --git a/src/main/java/org/springframework/data/elasticsearch/core/AbstractDefaultIndexOperations.java b/src/main/java/org/springframework/data/elasticsearch/core/AbstractDefaultIndexOperations.java index 54ea56bb2..0ac274c70 100644 --- a/src/main/java/org/springframework/data/elasticsearch/core/AbstractDefaultIndexOperations.java +++ b/src/main/java/org/springframework/data/elasticsearch/core/AbstractDefaultIndexOperations.java @@ -210,6 +210,7 @@ protected Document buildMapping(Class clazz) { // load mapping specified in Mapping annotation if present Mapping mappingAnnotation = AnnotatedElementUtils.findMergedAnnotation(clazz, Mapping.class); + if (mappingAnnotation != null) { String mappingPath = mappingAnnotation.mappingPath(); diff --git a/src/main/java/org/springframework/data/elasticsearch/core/DefaultReactiveIndexOperations.java b/src/main/java/org/springframework/data/elasticsearch/core/DefaultReactiveIndexOperations.java index a1aae3f59..712df1ef3 100644 --- a/src/main/java/org/springframework/data/elasticsearch/core/DefaultReactiveIndexOperations.java +++ b/src/main/java/org/springframework/data/elasticsearch/core/DefaultReactiveIndexOperations.java @@ -183,7 +183,11 @@ public Mono createMapping(Class clazz) { Mapping mappingAnnotation = AnnotatedElementUtils.findMergedAnnotation(clazz, Mapping.class); if (mappingAnnotation != null) { - return loadDocument(mappingAnnotation.mappingPath(), "@Mapping"); + String mappingPath = mappingAnnotation.mappingPath(); + + if (hasText(mappingPath)) { + return loadDocument(mappingAnnotation.mappingPath(), "@Mapping"); + } } String mapping = new MappingBuilder(converter).buildPropertyMapping(clazz);