fix test

Author: hmottestad

core/sail/elasticsearch-store/src/test/java/org/eclipse/rdf4j/sail/elasticsearchstore/compliance/ElasticsearchStoreRepositoryIT.java

@@ -49,9 +49,4 @@ public void testShutdownFollowedByInit() {
 		// ignore test
 	}
 
-	@Disabled
-	@Override
-	public void getAllStatements() {
-		// ignore test for now
-	}
 }

testsuites/repository/src/main/java/org/eclipse/rdf4j/testsuite/repository/RepositoryTest.java

@@ -13,7 +13,10 @@
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
+import java.util.List;
+import java.util.Objects;
 import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
 
 import org.eclipse.rdf4j.model.IRI;
 import org.eclipse.rdf4j.model.Literal;
@@ -114,6 +117,9 @@ public void setUp() throws Exception {
 
 	@AfterEach
 	public void tearDown() {
+		try (RepositoryConnection connection = testRepository.getConnection()) {
+			connection.clear();
+		}
 		testRepository.shutDown();
 	}
 
@@ -164,19 +170,25 @@ public void getAllStatements() {
 
 			for (int i = 0; i < 1024 * 32; i++) {
 				try (RepositoryResult<Statement> statements = conn.getStatements(null, null, null)) {
-					assertEquals(2, statements.stream().count());
+					List<Statement> collect = statements.stream().collect(Collectors.toList());
+					assertEquals(2, collect.size(), "Iteration " + i + " failed with data:\n"
+							+ collect.stream().map(Objects::toString).reduce((a, b) -> a + "\n" + b).orElse(""));
 				}
 			}
 
 			for (int i = 0; i < 1024 * 32; i++) {
 				try (RepositoryResult<Statement> statements = conn.getStatements(null, RDF.TYPE, null)) {
-					assertEquals(1, statements.stream().count());
+					List<Statement> collect = statements.stream().collect(Collectors.toList());
+					assertEquals(1, collect.size(), "Iteration " + i + " failed with data:\n"
+							+ collect.stream().map(Objects::toString).reduce((a, b) -> a + "\n" + b).orElse(""));
 				}
 			}
 
 			for (int i = 0; i < 1024 * 32; i++) {
 				try (RepositoryResult<Statement> statements = conn.getStatements(null, null, null)) {
-					assertEquals(2, statements.stream().count());
+					List<Statement> collect = statements.stream().collect(Collectors.toList());
+					assertEquals(2, collect.size(), "Iteration " + i + " failed with data:\n"
+							+ collect.stream().map(Objects::toString).reduce((a, b) -> a + "\n" + b).orElse(""));
 				}
 			}
 		}