You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2021/12/27 10:29:55 UTC

[flink] branch release-1.13 updated: [FLINK-23047] Ignore CassandraConnectorITCase until the flakiness of this test is fixed.

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
     new 4f81fc6  [FLINK-23047] Ignore CassandraConnectorITCase until the flakiness of this test is fixed.
4f81fc6 is described below

commit 4f81fc60eabe772b2c05f5eff9fea6b01e1e0d28
Author: Etienne Chauchot <ec...@apache.org>
AuthorDate: Mon Dec 27 11:08:42 2021 +0100

    [FLINK-23047] Ignore CassandraConnectorITCase until the flakiness of this test is fixed.
    
    This closes #18204.
---
 .../flink/streaming/connectors/cassandra/CassandraConnectorITCase.java  | 2 ++
 1 file changed, 2 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 6077fe5..f6fede9 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
@@ -59,6 +59,7 @@ import org.junit.Assert;
 import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.ClassRule;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.testcontainers.containers.CassandraContainer;
 
@@ -81,6 +82,7 @@ import static org.junit.Assert.assertTrue;
 
 /** IT cases for all cassandra sinks. */
 @SuppressWarnings("serial")
+@Ignore(value = "Flaky test")
 public class CassandraConnectorITCase
         extends WriteAheadSinkTestBase<
                 Tuple3<String, Integer, Integer>,