Pipe: Add parameter check for forwarding-pipe-requests

Author: SteveYurongSu

integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeAutoConflictIT.java

@@ -32,6 +32,7 @@
 
 import org.junit.Assert;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
@@ -76,6 +77,7 @@ public void setUp() {
     receiverEnv.initClusterEnvironment();
   }
 
+  @Ignore
   @Test
   public void testDoubleLivingAutoConflict() throws Exception {
     // Double living is two clusters each with a pipe connecting to the other.
@@ -225,6 +227,7 @@ public void testDoubleLivingAutoConflict() throws Exception {
         receiverEnv, "select * from root.**", "Time,root.db.d1.s1,", expectedResSet);
   }
 
+  @Ignore
   @Test
   public void testDoubleLivingAutoConflictTemplate() throws Exception {
     final DataNodeWrapper senderDataNode = senderEnv.getDataNodeWrapper(0);

integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeIdempotentIT.java

@@ -32,6 +32,7 @@
 
 import org.junit.Assert;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
@@ -43,6 +44,7 @@
 import java.util.Map;
 import java.util.Set;
 
+@Ignore
 @RunWith(IoTDBTestRunner.class)
 @Category({MultiClusterIT2AutoCreateSchema.class})
 public class IoTDBPipeIdempotentIT extends AbstractPipeDualAutoIT {
@@ -370,6 +372,7 @@ public void testRevokeRoleFromUserIdempotent() throws Exception {
         Collections.singleton("1,"));
   }
 
+  @Ignore
   @Test
   public void testDropUserIdempotent() throws Exception {
     testIdempotent(
@@ -381,6 +384,7 @@ public void testDropUserIdempotent() throws Exception {
         Collections.singleton("1,"));
   }
 
+  @Ignore
   @Test
   public void testDropRoleIdempotent() throws Exception {
     testIdempotent(

integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeLifeCycleIT.java

@@ -30,6 +30,7 @@
 import org.apache.iotdb.rpc.TSStatusCode;
 
 import org.junit.Assert;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
@@ -620,6 +621,7 @@ public void testReceiverAlreadyHaveTimeSeries() throws Exception {
     }
   }
 
+  @Ignore
   @Test
   public void testDoubleLiving() throws Exception {
     // Double living is two clusters with pipes connecting each other.

integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipeManualConflictIT.java

@@ -29,6 +29,7 @@
 import org.apache.iotdb.rpc.TSStatusCode;
 
 import org.junit.Assert;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
@@ -39,6 +40,7 @@
 import java.util.HashSet;
 import java.util.Map;
 
+@Ignore
 @RunWith(IoTDBTestRunner.class)
 @Category({MultiClusterIT2ManualCreateSchema.class})
 public class IoTDBPipeManualConflictIT extends AbstractPipeDualManualIT {

integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipeMetaLeaderChangeIT.java

@@ -32,6 +32,7 @@
 
 import org.junit.Assert;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
@@ -66,6 +67,7 @@ public void setUp() {
     receiverEnv.initClusterEnvironment();
   }
 
+  @Ignore
   @Test
   public void testConfigNodeLeaderChange() throws Exception {
     final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
@@ -125,6 +127,7 @@ public void testConfigNodeLeaderChange() throws Exception {
         receiverEnv, "count databases", "count,", Collections.singleton("20,"));
   }
 
+  @Ignore
   @Test
   public void testSchemaRegionLeaderChange() throws Exception {
     final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);

integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipeMetaRestartIT.java

@@ -29,6 +29,7 @@
 import org.apache.iotdb.rpc.TSStatusCode;
 
 import org.junit.Assert;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
@@ -40,6 +41,7 @@
 @RunWith(IoTDBTestRunner.class)
 @Category({MultiClusterIT2ManualCreateSchema.class})
 public class IoTDBPipeMetaRestartIT extends AbstractPipeDualManualIT {
+  @Ignore
   @Test
   public void testAutoRestartSchemaTask() throws Exception {
     final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
@@ -106,6 +108,7 @@ public void testAutoRestartSchemaTask() throws Exception {
         receiverEnv, "count timeseries", "count(timeseries),", Collections.singleton("20,"));
   }
 
+  @Ignore
   @Test
   public void testAutoRestartConfigTask() throws Exception {
     final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);

integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipeMultiSchemaRegionIT.java

@@ -29,6 +29,7 @@
 import org.apache.iotdb.rpc.TSStatusCode;
 
 import org.junit.Assert;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
@@ -41,6 +42,7 @@
 @RunWith(IoTDBTestRunner.class)
 @Category({MultiClusterIT2ManualCreateSchema.class})
 public class IoTDBPipeMultiSchemaRegionIT extends AbstractPipeDualManualIT {
+  @Ignore
   @Test
   public void testMultiSchemaRegion() throws Exception {
     final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);

integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeAutoConflictIT.java

@@ -33,6 +33,7 @@
 
 import org.junit.Assert;
 import org.junit.Before;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
@@ -76,6 +77,7 @@ public void setUp() {
     receiverEnv.initClusterEnvironment();
   }
 
+  @Ignore
   @Test
   public void testDoubleLivingAutoConflict() throws Exception {
     // Double living is two clusters each with a pipe connecting to the other.
@@ -173,6 +175,7 @@ public void testDoubleLivingAutoConflict() throws Exception {
     TableModelUtils.assertData("test", "test1", 0, 600, receiverEnv, handleFailure);
   }
 
+  @Ignore
   @Test
   public void testDoubleLivingAutoConflictTemplate() throws Exception {
     final DataNodeWrapper senderDataNode = senderEnv.getDataNodeWrapper(0);

integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeDataSinkIT.java

@@ -30,6 +30,7 @@
 
 import org.apache.tsfile.write.record.Tablet;
 import org.junit.Assert;
+import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
 import org.junit.runner.RunWith;
@@ -239,6 +240,7 @@ private void testSinkFormat(final String format) throws Exception {
     }
   }
 
+  @Ignore
   @Test
   public void testWriteBackSink() throws Exception {
     try (final SyncConfigNodeIServiceClient client =

integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeLifeCycleIT.java

@@ -575,6 +575,7 @@ public void testReceiverAlreadyHaveTimeSeries() throws Exception {
     }
   }
 
+  @Ignore
   @Test
   public void testDoubleLiving() throws Exception {
     boolean insertResult = true;