This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2413649b0c04b72a38e57d0a57f71d9ff5919274 Author: Chesnay Schepler <[email protected]> AuthorDate: Wed Apr 21 15:10:49 2021 +0200 [FLINK-20723][cassandra][tests] Retry on NoHostAvailableException --- .../streaming/connectors/cassandra/CassandraConnectorITCase.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java index 0b79877..1f7a34f 100644 --- a/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java +++ b/flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java @@ -47,6 +47,8 @@ import org.apache.flink.streaming.runtime.operators.WriteAheadSinkTestBase; import org.apache.flink.table.api.bridge.java.StreamTableEnvironment; import org.apache.flink.table.api.internal.TableEnvironmentInternal; import org.apache.flink.testutils.junit.FailsOnJava11; +import org.apache.flink.testutils.junit.RetryOnException; +import org.apache.flink.testutils.junit.RetryRule; import org.apache.flink.types.Row; import com.datastax.driver.core.Cluster; @@ -54,6 +56,7 @@ import com.datastax.driver.core.ConsistencyLevel; import com.datastax.driver.core.QueryOptions; import com.datastax.driver.core.ResultSet; import com.datastax.driver.core.Session; +import com.datastax.driver.core.exceptions.NoHostAvailableException; import com.datastax.driver.mapping.Mapper; import org.apache.cassandra.service.CassandraDaemon; import org.junit.AfterClass; @@ -61,6 +64,7 @@ import org.junit.Assert; import org.junit.Before; import org.junit.BeforeClass; import org.junit.ClassRule; +import org.junit.Rule; import org.junit.Test; import org.junit.experimental.categories.Category; import org.junit.rules.TemporaryFolder; @@ -92,6 +96,8 @@ import static org.junit.Assert.assertTrue; /** IT cases for all cassandra sinks. */ @SuppressWarnings("serial") @Category(FailsOnJava11.class) +// this test is known to be unstable, but the exact cause is unknown +@RetryOnException(times = 2, exception = NoHostAvailableException.class) public class CassandraConnectorITCase extends WriteAheadSinkTestBase< Tuple3<String, Integer, Integer>, @@ -99,6 +105,8 @@ public class CassandraConnectorITCase private static final Logger LOG = LoggerFactory.getLogger(CassandraConnectorITCase.class); + @Rule public final RetryRule retryRule = new RetryRule(); + private static final boolean EMBEDDED = true; private static EmbeddedCassandraService cassandra;
