You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2022/12/19 12:33:37 UTC
[iotdb] branch beyyes/fix_it created (now 0c00694e91)
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/fix_it
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 0c00694e91 fix it
This branch includes the following new commits:
new 0c00694e91 fix it
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: fix it
Posted by ca...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch beyyes/fix_it
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 0c00694e91a38a152c64e370292dee721e9ae1cc
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Mon Dec 19 20:33:22 2022 +0800
fix it
---
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 25 +++++-----------------
1 file changed, 5 insertions(+), 20 deletions(-)
diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterRegionLeaderBalancingIT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterRegionLeaderBalancingIT.java
index caab757870..40501fb8b5 100644
--- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterRegionLeaderBalancingIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBClusterRegionLeaderBalancingIT.java
@@ -24,12 +24,8 @@ import org.apache.iotdb.common.rpc.thrift.TTimePartitionSlot;
import org.apache.iotdb.commons.client.sync.SyncConfigNodeIServiceClient;
import org.apache.iotdb.commons.cluster.NodeStatus;
import org.apache.iotdb.commons.cluster.RegionRoleType;
-import org.apache.iotdb.commons.exception.IllegalPathException;
-import org.apache.iotdb.confignode.it.utils.ConfigNodeTestUtils;
import org.apache.iotdb.confignode.rpc.thrift.TDataPartitionReq;
import org.apache.iotdb.confignode.rpc.thrift.TDataPartitionTableResp;
-import org.apache.iotdb.confignode.rpc.thrift.TSchemaPartitionReq;
-import org.apache.iotdb.confignode.rpc.thrift.TSchemaPartitionTableResp;
import org.apache.iotdb.confignode.rpc.thrift.TSetStorageGroupReq;
import org.apache.iotdb.confignode.rpc.thrift.TShowDataNodesResp;
import org.apache.iotdb.confignode.rpc.thrift.TShowRegionReq;
@@ -169,8 +165,7 @@ public class IoTDBClusterRegionLeaderBalancingIT {
}
@Test
- public void testMCFLeaderDistribution()
- throws IOException, InterruptedException, TException, IllegalPathException {
+ public void testMCFLeaderDistribution() throws IOException, InterruptedException, TException {
final int testConfigNodeNum = 1;
final int testDataNodeNum = 3;
final int retryNum = 100;
@@ -187,16 +182,6 @@ public class IoTDBClusterRegionLeaderBalancingIT {
status = client.setStorageGroup(setReq);
Assert.assertEquals(TSStatusCode.SUCCESS_STATUS.getStatusCode(), status.getCode());
- // Create a SchemaRegionGroup for each StorageGroup
- TSchemaPartitionTableResp schemaPartitionTableResp =
- client.getOrCreateSchemaPartitionTable(
- new TSchemaPartitionReq(
- ConfigNodeTestUtils.generatePatternTreeBuffer(
- new String[] {sg + i + "." + "d"})));
- Assert.assertEquals(
- TSStatusCode.SUCCESS_STATUS.getStatusCode(),
- schemaPartitionTableResp.getStatus().getCode());
-
// Create a DataRegionGroup for each StorageGroup
Map<TSeriesPartitionSlot, TTimeSlotList> seriesSlotMap = new HashMap<>();
seriesSlotMap.put(
@@ -232,9 +217,9 @@ public class IoTDBClusterRegionLeaderBalancingIT {
// All DataNodes have Region-leader
isDistributionBalanced = leaderCounter.size() == testDataNodeNum;
- // Each DataNode has exactly 4 Region-leader
+ // Each DataNode has exactly 2 Region-leader
for (AtomicInteger leaderCount : leaderCounter.values()) {
- if (leaderCount.get() != 4) {
+ if (leaderCount.get() != 2) {
isDistributionBalanced = false;
}
}
@@ -291,9 +276,9 @@ public class IoTDBClusterRegionLeaderBalancingIT {
// Only Running DataNodes have Region-leader
isDistributionBalanced = leaderCounter.size() == testDataNodeNum - 1;
- // Each Running DataNode has exactly 6 Region-leader
+ // Each Running DataNode has exactly 3 Region-leader
for (AtomicInteger leaderCount : leaderCounter.values()) {
- if (leaderCount.get() != 6) {
+ if (leaderCount.get() != 3) {
isDistributionBalanced = false;
}
}