fix tests

Author: jt2594838

integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBRestartRatisIT.java

@@ -261,7 +261,7 @@ public void testRecoverWALMismatchDataType() throws Exception {
     try (Connection connection = EnvFactory.getEnv().getConnection();
         Statement statement = connection.createStatement()) {
 
-      try (ResultSet resultSet = statement.executeQuery("select * from root.**")) {
+      try (ResultSet resultSet = statement.executeQuery("select * from root.turbine1.**")) {
         assertNotNull(resultSet);
         int cnt = 0;
         assertEquals(3, resultSet.getMetaData().getColumnCount());
@@ -289,7 +289,7 @@ public void testRecoverWALDeleteSchema() throws Exception {
     try (Connection connection = EnvFactory.getEnv().getConnection();
         Statement statement = connection.createStatement()) {
 
-      try (ResultSet resultSet = statement.executeQuery("select * from root.**")) {
+      try (ResultSet resultSet = statement.executeQuery("select * from root.turbine1.**")) {
         assertNotNull(resultSet);
         int cnt = 0;
         assertEquals(2, resultSet.getMetaData().getColumnCount());
@@ -356,7 +356,7 @@ public void testRecoverFromFlushMemTableError() throws Exception {
     try (Connection connection = EnvFactory.getEnv().getConnection();
         Statement statement = connection.createStatement()) {
 
-      try (ResultSet resultSet = statement.executeQuery("select * from root.**")) {
+      try (ResultSet resultSet = statement.executeQuery("select * from root.turbine1.**")) {
         assertNotNull(resultSet);
         int cnt = 0;
         while (resultSet.next()) {

integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeExtractorIT.java

@@ -72,6 +72,8 @@ public void setUp() {
         .setEnableSeqSpaceCompaction(false)
         .setEnableUnseqSpaceCompaction(false)
         .setEnableCrossSpaceCompaction(false);
+    senderEnv.getConfig().getConfigNodeConfig().setLeaderDistributionPolicy("HASH");
+
     receiverEnv
         .getConfig()
         .getCommonConfig()