WIP

Author: sothawo

src/test/java/org/springframework/data/elasticsearch/repositories/custommethod/CustomMethodRepositoryBaseTests.java

@@ -1431,13 +1431,15 @@ public void streamMethodsShouldWorkWithLargeResultSets() {
 		// given
 		List<SampleEntity> entities = createSampleEntities("abc", 10001);
 		repository.saveAll(entities);
+		operations.indexOps(SampleEntity.class).refresh();
 
 		// when
 		Stream<SampleEntity> stream = streamingRepository.findByType("abc");
 
 		// then
 		assertThat(stream).isNotNull();
-		assertThat(stream.count()).isEqualTo(10001L);
+		long count = stream.count();
+		assertThat(count).isEqualTo(10001L);
 	}
 
 	@Test // DATAES-605
@@ -1734,6 +1736,7 @@ public void setVersion(@Nullable java.lang.Long version) {
 	 * @author Mohsin Husen
 	 * @author Kevin Leturc
 	 */
+	@SuppressWarnings("SpringDataRepositoryMethodParametersInspection")
 	public interface SampleCustomMethodRepository extends ElasticsearchRepository<SampleEntity, String> {
 
 		Page<SampleEntity> findByType(String type, Pageable pageable);

src/test/java/org/springframework/data/elasticsearch/repositories/custommethod/CustomMethodRepositoryTests.java

@@ -15,6 +15,7 @@
  */
 package org.springframework.data.elasticsearch.repositories.custommethod;
 
+import org.junit.jupiter.api.Disabled;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Import;
@@ -42,4 +43,9 @@ IndexNameProvider indexNameProvider() {
 			return new IndexNameProvider("custom-method-repository");
 		}
 	}
+
+	@Disabled("this test crashes the transport client connection in some dockerized test container setup")
+	@Override
+	public void streamMethodsShouldWorkWithLargeResultSets() {
+	}
 }