disabled

apache · Feb 1, 2023 · d42c521 · d42c521
1 parent 04b49e6
commit d42c521
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/...unnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java b/...unnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
@@ -39,6 +39,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.awaitility.Awaitility;
 import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.testcontainers.shaded.org.apache.commons.lang3.tuple.ImmutablePair;
 
@@ -65,6 +66,7 @@ public class ClusterFaultToleranceIT {
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testBatchJobRunOkIn3Node() throws ExecutionException, InterruptedException {
         String testCaseName = "testBatchJobRunOkIn3Node";
         String testClusterName = "ClusterFaultToleranceIT_testBatchJobRunOkIn3Node";
@@ -172,6 +174,7 @@ private ImmutablePair<String, String> createTestResources(@NonNull String testCa
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testStreamJobRunOkIn3Node() throws ExecutionException, InterruptedException {
         String testCaseName = "testStreamJobRunOkIn3Node";
         String testClusterName = "ClusterFaultToleranceIT_testStreamJobRunOkIn3Node";
@@ -250,6 +253,7 @@ public void testStreamJobRunOkIn3Node() throws ExecutionException, InterruptedEx
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testBatchJobRestoreIn3NodeWorkerDown() throws ExecutionException, InterruptedException {
         String testCaseName = "testBatchJobRestoreIn3NodeWorkerDown";
         String testClusterName = "ClusterFaultToleranceIT_testBatchJobRestoreIn3NodeWorkerDown";
@@ -330,6 +334,7 @@ public void testBatchJobRestoreIn3NodeWorkerDown() throws ExecutionException, In
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testStreamJobRestoreIn3NodeWorkerDown() throws ExecutionException, InterruptedException {
         String testCaseName = "testStreamJobRestoreIn3NodeWorkerDown";
         String testClusterName = "ClusterFaultToleranceIT_testStreamJobRestoreIn3NodeWorkerDown";
@@ -425,6 +430,7 @@ public void testStreamJobRestoreIn3NodeWorkerDown() throws ExecutionException, I
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testBatchJobRestoreIn3NodeMasterDown() throws ExecutionException, InterruptedException {
         String testCaseName = "testBatchJobRestoreIn3NodeMasterDown";
         String testClusterName = "ClusterFaultToleranceIT_testBatchJobRestoreIn3NodeMasterDown";
@@ -505,6 +511,7 @@ public void testBatchJobRestoreIn3NodeMasterDown() throws ExecutionException, In
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testStreamJobRestoreIn3NodeMasterDown() throws ExecutionException, InterruptedException {
         String testCaseName = "testStreamJobRestoreIn3NodeMasterDown";
         String testClusterName = "ClusterFaultToleranceIT_testStreamJobRestoreIn3NodeMasterDown";
@@ -599,6 +606,7 @@ public void testStreamJobRestoreIn3NodeMasterDown() throws ExecutionException, I
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testStreamJobRestoreInAllNodeDown() throws ExecutionException, InterruptedException {
         String testCaseName = "testStreamJobRestoreInAllNodeDown";
         String testClusterName = "ClusterFaultToleranceIT_testStreamJobRestoreInAllNodeDown";

diff --git a/...ase/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java b/...ase/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceTwoPipelineIT.java
@@ -38,6 +38,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.awaitility.Awaitility;
 import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.testcontainers.shaded.org.apache.commons.lang3.tuple.ImmutablePair;
 
@@ -66,6 +67,7 @@ public class ClusterFaultToleranceTwoPipelineIT {
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testTwoPipelineBatchJobRunOkIn3Node() throws ExecutionException, InterruptedException {
         String testCaseName = "testTwoPipelineBatchJobRunOkIn3Node";
         String testClusterName = "ClusterFaultToleranceTwoPipelineIT_testTwoPipelineBatchJobRunOkIn3Node";
@@ -177,6 +179,7 @@ private ImmutablePair<String, String> createTestResources(@NonNull String testCa
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testTwoPipelineStreamJobRunOkIn3Node() throws ExecutionException, InterruptedException {
         String testCaseName = "testTwoPipelineStreamJobRunOkIn3Node";
         String testClusterName = "ClusterFaultToleranceTwoPipelineIT_testTwoPipelineStreamJobRunOkIn3Node";
@@ -257,6 +260,7 @@ public void testTwoPipelineStreamJobRunOkIn3Node() throws ExecutionException, In
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testTwoPipelineBatchJobRestoreIn3NodeWorkerDown() throws ExecutionException, InterruptedException {
         String testCaseName = "testTwoPipelineBatchJobRestoreIn3NodeWorkerDown";
         String testClusterName = "ClusterFaultToleranceTwoPipelineIT_testTwoPipelineBatchJobRestoreIn3NodeWorkerDown";
@@ -339,6 +343,7 @@ public void testTwoPipelineBatchJobRestoreIn3NodeWorkerDown() throws ExecutionEx
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testTwoPipelineStreamJobRestoreIn3NodeWorkerDown() throws ExecutionException, InterruptedException {
         String testCaseName = "testTwoPipelineStreamJobRestoreIn3NodeWorkerDown";
         String testClusterName = "ClusterFaultToleranceTwoPipelineIT_testTwoPipelineStreamJobRestoreIn3NodeWorkerDown";
@@ -436,6 +441,7 @@ public void testTwoPipelineStreamJobRestoreIn3NodeWorkerDown() throws ExecutionE
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testTwoPipelineBatchJobRestoreIn3NodeMasterDown() throws ExecutionException, InterruptedException {
         String testCaseName = "testTwoPipelineBatchJobRestoreIn3NodeMasterDown";
         String testClusterName = "ClusterFaultToleranceTwoPipelineIT_testTwoPipelineBatchJobRestoreIn3NodeMasterDown";
@@ -516,6 +522,7 @@ public void testTwoPipelineBatchJobRestoreIn3NodeMasterDown() throws ExecutionEx
 
     @SuppressWarnings("checkstyle:RegexpSingleline")
     @Test
+    @Disabled
     public void testTwoPipelineStreamJobRestoreIn3NodeMasterDown() throws ExecutionException, InterruptedException {
         String testCaseName = "testTwoPipelineStreamJobRestoreIn3NodeMasterDown";
         String testClusterName = "ClusterFaultToleranceTwoPipelineIT_testTwoPipelineStreamJobRestoreIn3NodeMasterDown";