diff --git a/janusgraph-cql/src/test/java/org/janusgraph/core/cql/CQLConfiguredGraphFactoryTest.java b/janusgraph-cql/src/test/java/org/janusgraph/core/cql/CQLConfiguredGraphFactoryTest.java index 1daae137df..704b39b516 100644 --- a/janusgraph-cql/src/test/java/org/janusgraph/core/cql/CQLConfiguredGraphFactoryTest.java +++ b/janusgraph-cql/src/test/java/org/janusgraph/core/cql/CQLConfiguredGraphFactoryTest.java @@ -15,6 +15,7 @@ package org.janusgraph.core.cql; import com.datastax.driver.core.Session; +import io.github.artsok.RepeatedIfExceptionsTest; import org.apache.commons.configuration2.MapConfiguration; import org.janusgraph.JanusGraphCassandraContainer; import org.janusgraph.core.AbstractConfiguredGraphFactoryTest; @@ -130,5 +131,11 @@ public void dropGraphShouldRemoveGraphKeyspace() throws Exception { ConfiguredGraphFactory.close(graphName); } } + + @RepeatedIfExceptionsTest(repeats = 3) + @Override + public void updateConfigurationShouldRemoveGraphFromCache() throws Exception { + super.updateConfigurationShouldRemoveGraphFromCache(); + } } diff --git a/janusgraph-cql/src/test/java/org/janusgraph/graphdb/cql/CQLGraphTest.java b/janusgraph-cql/src/test/java/org/janusgraph/graphdb/cql/CQLGraphTest.java index 5860e82cee..93ea06fdff 100644 --- a/janusgraph-cql/src/test/java/org/janusgraph/graphdb/cql/CQLGraphTest.java +++ b/janusgraph-cql/src/test/java/org/janusgraph/graphdb/cql/CQLGraphTest.java @@ -14,6 +14,7 @@ package org.janusgraph.graphdb.cql; +import io.github.artsok.RepeatedIfExceptionsTest; import org.apache.commons.lang3.RandomStringUtils; import org.apache.commons.lang3.exception.ExceptionUtils; import org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversalSource; @@ -52,6 +53,7 @@ import java.util.List; import java.util.Map; import java.util.Random; +import java.util.concurrent.ExecutionException; import java.util.stream.Stream; import static org.janusgraph.diskstorage.cql.CQLConfigOptions.ATOMIC_BATCH_MUTATE; @@ -128,6 +130,12 @@ public void simpleLogTest(boolean useStringId) { } } + @RepeatedIfExceptionsTest(repeats = 3) + @Override + public void testReindexingForEdgeIndex() throws ExecutionException, InterruptedException { + super.testReindexingForEdgeIndex(); + } + protected static Stream generateConsistencyConfigs() { return Arrays.stream(new Arguments[]{ arguments(true, true, 20), diff --git a/janusgraph-cql/src/test/java/org/janusgraph/hadoop/CQLIndexManagementIT.java b/janusgraph-cql/src/test/java/org/janusgraph/hadoop/CQLIndexManagementIT.java index 1fc2540566..9e60dda318 100644 --- a/janusgraph-cql/src/test/java/org/janusgraph/hadoop/CQLIndexManagementIT.java +++ b/janusgraph-cql/src/test/java/org/janusgraph/hadoop/CQLIndexManagementIT.java @@ -14,11 +14,15 @@ package org.janusgraph.hadoop; +import io.github.artsok.RepeatedIfExceptionsTest; import org.janusgraph.JanusGraphCassandraContainer; +import org.janusgraph.diskstorage.BackendException; import org.janusgraph.diskstorage.configuration.WriteConfiguration; import org.testcontainers.junit.jupiter.Container; import org.testcontainers.junit.jupiter.Testcontainers; +import java.util.concurrent.ExecutionException; + @Testcontainers public class CQLIndexManagementIT extends AbstractIndexManagementIT { @Container @@ -28,4 +32,10 @@ public class CQLIndexManagementIT extends AbstractIndexManagementIT { public WriteConfiguration getConfiguration() { return cql.getConfiguration(getClass().getSimpleName().toLowerCase()).getConfiguration(); } + + @RepeatedIfExceptionsTest(repeats = 3) + @Override + public void testRepairRelationIndex() throws ExecutionException, InterruptedException, BackendException { + super.testRepairRelationIndex(); + } } diff --git a/janusgraph-es/src/test/java/org/janusgraph/diskstorage/es/CQLElasticsearchTest.java b/janusgraph-es/src/test/java/org/janusgraph/diskstorage/es/CQLElasticsearchTest.java index f38c2ae867..4fa030f195 100644 --- a/janusgraph-es/src/test/java/org/janusgraph/diskstorage/es/CQLElasticsearchTest.java +++ b/janusgraph-es/src/test/java/org/janusgraph/diskstorage/es/CQLElasticsearchTest.java @@ -14,12 +14,15 @@ package org.janusgraph.diskstorage.es; +import io.github.artsok.RepeatedIfExceptionsTest; import org.janusgraph.JanusGraphCassandraContainer; import org.janusgraph.diskstorage.configuration.ModifiableConfiguration; import org.junit.jupiter.api.Disabled; import org.testcontainers.junit.jupiter.Container; import org.testcontainers.junit.jupiter.Testcontainers; +import java.util.concurrent.ExecutionException; + @Testcontainers public class CQLElasticsearchTest extends ElasticsearchJanusGraphIndexTest { @@ -34,4 +37,10 @@ public ModifiableConfiguration getStorageConfiguration() { @Override @Disabled("CQL seems to not clear storage correctly") public void testClearStorage() {} + + @RepeatedIfExceptionsTest(repeats = 3) + @Override + public void testIndexUpdatesWithoutReindex() throws InterruptedException, ExecutionException { + super.testIndexUpdatesWithoutReindex(); + } } diff --git a/janusgraph-test/src/test/java/org/janusgraph/diskstorage/cache/ExpirationCacheTest.java b/janusgraph-test/src/test/java/org/janusgraph/diskstorage/cache/ExpirationCacheTest.java index 6cbe9e119b..5ee9a601e4 100644 --- a/janusgraph-test/src/test/java/org/janusgraph/diskstorage/cache/ExpirationCacheTest.java +++ b/janusgraph-test/src/test/java/org/janusgraph/diskstorage/cache/ExpirationCacheTest.java @@ -26,7 +26,6 @@ import org.janusgraph.diskstorage.keycolumnvalue.cache.ExpirationKCVSCache; import org.janusgraph.diskstorage.keycolumnvalue.cache.KCVSCache; import org.janusgraph.diskstorage.util.BufferUtil; -import org.junit.jupiter.api.Test; import java.time.Duration; import java.time.Instant; @@ -97,7 +96,7 @@ private void testExpiration(Duration expirationTime) throws Exception { verifyResults(key, keys, query, 4); } - @Test + @RepeatedIfExceptionsTest(repeats = 3) public void testGracePeriod() throws Exception { testGracePeriod(Duration.ofMillis(200)); testGracePeriod(Duration.ZERO);