diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeClusterIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeClusterIT.java
index 7c07e5073dfb2..632e74e19eba7 100644
--- a/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeClusterIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/pipe/it/IoTDBPipeClusterIT.java
@@ -41,6 +41,7 @@
 import org.junit.After;
 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;
@@ -566,8 +567,13 @@ public void testRegisteringNewDataNodeAfterTransferringData() throws Exception {
     }
   }
 
+  @Ignore(
+      "Currently ignore this test because this test intends to test the behaviour when the sender has"
+          + " a temporary node joined and then removed, but in reality it just tears it down. In this"
+          + " circumstance the IT may fail. However, the \"remove\" method is currently not provided thus"
+          + " we ignore this test now.")
   @Test
-  public void testNewDataNodeFailureAfterTransferringData() throws Exception {
+  public void testNewDataNodeFailureParallelToTransferringData() throws Exception {
     DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
 
     String receiverIp = receiverDataNode.getIp();
@@ -605,7 +611,7 @@ public void testNewDataNodeFailureAfterTransferringData() throws Exception {
 
       senderEnv.registerNewDataNode(false);
       senderEnv.startDataNode(senderEnv.getDataNodeWrapperList().size() - 1);
-      senderEnv.shutdownDataNode(senderEnv.getDataNodeWrapperList().size() - 1); // ctrl + c
+      senderEnv.shutdownDataNode(senderEnv.getDataNodeWrapperList().size() - 1);
       senderEnv.getDataNodeWrapperList().remove(senderEnv.getDataNodeWrapperList().size() - 1);
       ((AbstractEnv) senderEnv).testWorkingNoUnknown();