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:26:38 UTC
[flink] branch master 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 master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 509530b [FLINK-23047] Ignore CassandraConnectorITCase until the flakiness of this test is fixed.
509530b is described below
commit 509530bc79c8b9acce0bc86805956d624fc3f0fa
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 402aec5..2d3ec33 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
@@ -60,6 +60,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;
@@ -82,6 +83,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>,