diff --git a/src/test/java/org/springframework/data/elasticsearch/core/mapping/EntityCustomConversionIntegrationTests.java b/src/test/java/org/springframework/data/elasticsearch/core/mapping/EntityCustomConversionIntegrationTests.java
index 900af4ac4..9e5a8a4c5 100644
--- a/src/test/java/org/springframework/data/elasticsearch/core/mapping/EntityCustomConversionIntegrationTests.java
+++ b/src/test/java/org/springframework/data/elasticsearch/core/mapping/EntityCustomConversionIntegrationTests.java
@@ -108,6 +108,7 @@ public class EntityCustomConversionIntegrationTests {
 				.build();
 
 		Entity savedEntity = operations.save(entity);
+        operations.indexOps(Entity.class).refresh();
 
 		SearchHits<Entity> searchHits = operations.search(Query.findAll(), Entity.class);
 		assertThat(searchHits.getTotalHits()).isEqualTo(1);