[ci] removing Flaky

debezium · Apr 11, 2024 · 5b0a06c · 5b0a06c
1 parent f8fd56c
commit 5b0a06c
Show file tree

Hide file tree

Showing 6 changed files with 0 additions and 50 deletions.
diff --git a/src/test/java/io/debezium/connector/informix/AbstractInformixDefaultValueIT.java b/src/test/java/io/debezium/connector/informix/AbstractInformixDefaultValueIT.java
@@ -21,9 +21,7 @@
 import org.apache.kafka.connect.source.SourceRecord;
 import org.junit.After;
 import org.junit.Before;
-import org.junit.Rule;
 import org.junit.Test;
-import org.junit.rules.TestRule;
 
 import io.debezium.config.Configuration;
 import io.debezium.connector.informix.util.TestHelper;
@@ -32,8 +30,6 @@
 import io.debezium.doc.FixFor;
 import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
 import io.debezium.jdbc.TemporalPrecisionMode;
-import io.debezium.junit.ConditionalFail;
-import io.debezium.junit.Flaky;
 
 /**
  * Abstract default value integration test.
@@ -46,9 +42,6 @@
  */
 public abstract class AbstractInformixDefaultValueIT extends AbstractAsyncEngineConnectorTest {
 
-    @Rule
-    public TestRule conditionalFail = new ConditionalFail();
-
     private InformixConnection connection;
     private Configuration config;
 
@@ -81,7 +74,6 @@ public void after() throws SQLException {
 
     @Test
     @FixFor("DBZ-4990")
-    @Flaky("DBZ-7542")
     public void shouldHandleBooleanDefaultTypes() throws Exception {
         List<ColumnDefinition> columnDefinitions = List.of(
                 new ColumnDefinition("val_boolean", "BOOLEAN",
@@ -94,7 +86,6 @@ public void shouldHandleBooleanDefaultTypes() throws Exception {
 
     @Test
     @FixFor("DBZ-4990")
-    @Flaky("DBZ-7542")
     public void shouldHandleNumericDefaultTypes() throws Exception {
         // TODO: remove once https://github.com/Apicurio/apicurio-registry/issues/2990 is fixed
         if (VerifyRecord.isApucurioAvailable()) {
@@ -128,7 +119,6 @@ public void shouldHandleNumericDefaultTypes() throws Exception {
 
     @Test
     @FixFor("DBZ-4990")
-    @Flaky("DBZ-7542")
     public void shouldHandleFloatPointDefaultTypes() throws Exception {
         // TODO: remove once https://github.com/Apicurio/apicurio-registry/issues/2980 is fixed
         if (VerifyRecord.isApucurioAvailable()) {
@@ -162,7 +152,6 @@ public void shouldHandleFloatPointDefaultTypes() throws Exception {
 
     @Test
     @FixFor("DBZ-4990")
-    @Flaky("DBZ-7542")
     public void shouldHandleCharacterDefaultTypes() throws Exception {
         List<ColumnDefinition> columnDefinitions = Arrays.asList(
                 new ColumnDefinition("val_char", "char(5)",
@@ -191,7 +180,6 @@ public void shouldHandleCharacterDefaultTypes() throws Exception {
 
     @Test
     @FixFor("DBZ-4990")
-    @Flaky("DBZ-7542")
     public void shouldHandleDateTimeDefaultTypes() throws Exception {
         List<ColumnDefinition> columnDefinitions = Arrays.asList(
                 new ColumnDefinition("val_date", "DATE",

diff --git a/src/test/java/io/debezium/connector/informix/BlockingSnapshotIT.java b/src/test/java/io/debezium/connector/informix/BlockingSnapshotIT.java
@@ -12,24 +12,17 @@
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Ignore;
-import org.junit.Rule;
 import org.junit.Test;
-import org.junit.rules.TestRule;
 
 import io.debezium.config.Configuration.Builder;
 import io.debezium.connector.informix.InformixConnectorConfig.SnapshotMode;
 import io.debezium.connector.informix.util.TestHelper;
 import io.debezium.jdbc.JdbcConnection;
-import io.debezium.junit.ConditionalFail;
-import io.debezium.junit.Flaky;
 import io.debezium.pipeline.AbstractBlockingSnapshotTest;
 import io.debezium.relational.history.SchemaHistory;
 
 public class BlockingSnapshotIT extends AbstractBlockingSnapshotTest {
 
-    @Rule
-    public TestRule conditionalFail = new ConditionalFail();
-
     private InformixConnection connection;
 
     @Before
@@ -160,7 +153,6 @@ public void readsSchemaOnlyForSignaledTables() throws Exception {
     }
 
     @Test
-    @Flaky("DBZ-7543")
     public void executeBlockingSnapshotWhileStreaming() throws Exception {
         super.executeBlockingSnapshotWhileStreaming();
     }

diff --git a/src/test/java/io/debezium/connector/informix/InformixCdcTypesIT.java b/src/test/java/io/debezium/connector/informix/InformixCdcTypesIT.java
@@ -29,7 +29,6 @@
 import io.debezium.connector.informix.util.TestHelper;
 import io.debezium.data.SourceRecordAssert;
 import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
-import io.debezium.junit.Flaky;
 import io.debezium.relational.RelationalDatabaseConnectorConfig;
 import io.debezium.relational.RelationalDatabaseConnectorConfig.DecimalHandlingMode;
 import io.debezium.time.Date;
@@ -86,7 +85,6 @@ public void after() throws SQLException {
     }
 
     @Test
-    @Flaky("DBZ-7531")
     public void testTypes() throws Exception {
 
         final Configuration config = TestHelper.defaultConfig()

diff --git a/src/test/java/io/debezium/connector/informix/InformixConnectorIT.java b/src/test/java/io/debezium/connector/informix/InformixConnectorIT.java
@@ -26,9 +26,7 @@
 import org.apache.kafka.connect.source.SourceRecord;
 import org.junit.After;
 import org.junit.Before;
-import org.junit.Rule;
 import org.junit.Test;
-import org.junit.rules.TestRule;
 
 import io.debezium.config.CommonConnectorConfig;
 import io.debezium.config.Configuration;
@@ -41,8 +39,6 @@
 import io.debezium.data.VerifyRecord;
 import io.debezium.doc.FixFor;
 import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
-import io.debezium.junit.ConditionalFail;
-import io.debezium.junit.Flaky;
 import io.debezium.junit.logging.LogInterceptor;
 import io.debezium.relational.RelationalDatabaseSchema;
 import io.debezium.relational.history.MemorySchemaHistory;
@@ -57,9 +53,6 @@
  */
 public class InformixConnectorIT extends AbstractAsyncEngineConnectorTest {
 
-    @Rule
-    public TestRule conditionalFail = new ConditionalFail();
-
     private InformixConnection connection;
 
     @Before
@@ -458,14 +451,12 @@ public void updatePrimaryKeyWithRestartInMiddle() throws Exception {
 
     @Test
     @FixFor("DBZ-1069")
-    @Flaky("DBZ-7531")
     public void verifyOffsetsWithoutOnlineUpd() throws Exception {
         verifyOffsets(false);
     }
 
     @Test
     @FixFor("DBZ-7531")
-    @Flaky("DBZ-7531")
     public void verifyOffsetsWithOnlineUpd() throws Exception {
         verifyOffsets(true);
     }
@@ -800,21 +791,18 @@ private void restartInTheMiddleOfTx(boolean restartJustAfterSnapshot, boolean af
 
     @Test
     @FixFor("DBZ-1128")
-    @Flaky("DBZ-7539")
     public void restartInTheMiddleOfTxAfterSnapshot() throws Exception {
         restartInTheMiddleOfTx(true, false);
     }
 
     @Test
     @FixFor("DBZ-1128")
-    @Flaky("DBZ-7539")
     public void restartInTheMiddleOfTxAfterCompletedTx() throws Exception {
         restartInTheMiddleOfTx(false, true);
     }
 
     @Test
     @FixFor("DBZ-1128")
-    @Flaky("DBZ-7539")
     public void restartInTheMiddleOfTx() throws Exception {
         restartInTheMiddleOfTx(false, false);
     }

diff --git a/src/test/java/io/debezium/connector/informix/SchemaHistoryTopicIT.java b/src/test/java/io/debezium/connector/informix/SchemaHistoryTopicIT.java
@@ -17,17 +17,13 @@
 import org.apache.kafka.connect.source.SourceRecord;
 import org.junit.After;
 import org.junit.Before;
-import org.junit.Rule;
 import org.junit.Test;
-import org.junit.rules.TestRule;
 
 import io.debezium.config.Configuration;
 import io.debezium.connector.informix.InformixConnectorConfig.SnapshotMode;
 import io.debezium.connector.informix.util.TestHelper;
 import io.debezium.doc.FixFor;
 import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
-import io.debezium.junit.ConditionalFail;
-import io.debezium.junit.Flaky;
 
 /**
  * Integration test for the user-facing history topic of the Debezium Informix Server connector.
@@ -38,9 +34,6 @@
  */
 public class SchemaHistoryTopicIT extends AbstractAsyncEngineConnectorTest {
 
-    @Rule
-    public TestRule conditionalFail = new ConditionalFail();
-
     private InformixConnection connection;
 
     @Before
@@ -80,7 +73,6 @@ public void after() throws SQLException {
 
     @Test
     @FixFor("DBZ-1904")
-    @Flaky("DBZ-7556")
     public void snapshotSchemaChanges() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int TABLES = 2;

diff --git a/src/test/java/io/debezium/connector/informix/TransactionMetadataIT.java b/src/test/java/io/debezium/connector/informix/TransactionMetadataIT.java
@@ -18,16 +18,12 @@
 import org.apache.kafka.connect.source.SourceRecord;
 import org.junit.After;
 import org.junit.Before;
-import org.junit.Rule;
 import org.junit.Test;
-import org.junit.rules.TestRule;
 
 import io.debezium.config.Configuration;
 import io.debezium.connector.informix.InformixConnectorConfig.SnapshotMode;
 import io.debezium.connector.informix.util.TestHelper;
 import io.debezium.embedded.async.AbstractAsyncEngineConnectorTest;
-import io.debezium.junit.ConditionalFail;
-import io.debezium.junit.Flaky;
 import io.debezium.util.Collect;
 
 /**
@@ -36,9 +32,6 @@
  */
 public class TransactionMetadataIT extends AbstractAsyncEngineConnectorTest {
 
-    @Rule
-    public TestRule conditionalFail = new ConditionalFail();
-
     private InformixConnection connection;
 
     @Before
@@ -75,7 +68,6 @@ public void after() throws SQLException {
     }
 
     @Test
-    @Flaky("DBZ-7540")
     public void transactionMetadata() throws Exception {
         final int RECORDS_PER_TABLE = 5;
         final int ID_START = 10;