Skip to content

Commit b634204

Browse files
committed
fix
1 parent beed891 commit b634204

File tree

2 files changed

+16
-16
lines changed

2 files changed

+16
-16
lines changed

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ClusterSchemaInfo.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -679,17 +679,17 @@ public int getMinRegionGroupNum(
679679
final String database, final TConsensusGroupType consensusGroupType) {
680680
databaseReadWriteLock.readLock().lock();
681681
try {
682-
final TDatabaseSchema storageGroupSchema =
682+
final TDatabaseSchema databaseSchema =
683683
(PathUtils.isTableModelDatabase(database) ? tableModelMTree : treeModelMTree)
684684
.getDatabaseNodeByDatabasePath(getQualifiedDatabasePartialPath(database))
685685
.getAsMNode()
686686
.getDatabaseSchema();
687687
switch (consensusGroupType) {
688688
case SchemaRegion:
689-
return storageGroupSchema.getMinSchemaRegionGroupNum();
689+
return databaseSchema.getMinSchemaRegionGroupNum();
690690
case DataRegion:
691691
default:
692-
return storageGroupSchema.getMinDataRegionGroupNum();
692+
return databaseSchema.getMinDataRegionGroupNum();
693693
}
694694
} catch (final MetadataException e) {
695695
LOGGER.warn(ERROR_NAME, e);

iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/schema/ConfigMTreeTest.java

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -268,11 +268,11 @@ public void testSerialization() throws Exception {
268268
};
269269
for (int i = 0; i < pathList.length; i++) {
270270
root.setStorageGroup(pathList[i]);
271-
final IDatabaseMNode<IConfigMNode> storageGroupMNode =
271+
final IDatabaseMNode<IConfigMNode> databaseMNode =
272272
root.getDatabaseNodeByDatabasePath(pathList[i]);
273-
storageGroupMNode.getAsMNode().getDatabaseSchema().setDataReplicationFactor(i);
274-
storageGroupMNode.getAsMNode().getDatabaseSchema().setSchemaReplicationFactor(i);
275-
storageGroupMNode.getAsMNode().getDatabaseSchema().setTimePartitionInterval(i);
273+
databaseMNode.getAsMNode().getDatabaseSchema().setDataReplicationFactor(i);
274+
databaseMNode.getAsMNode().getDatabaseSchema().setSchemaReplicationFactor(i);
275+
databaseMNode.getAsMNode().getDatabaseSchema().setTimePartitionInterval(i);
276276
root.getNodeWithAutoCreate(pathList[i].concatNode("a")).setSchemaTemplateId(i);
277277
}
278278

@@ -284,11 +284,11 @@ public void testSerialization() throws Exception {
284284
newTree.deserialize(inputStream);
285285

286286
for (int i = 0; i < pathList.length; i++) {
287-
final TDatabaseSchema storageGroupSchema =
287+
final TDatabaseSchema databaseSchema =
288288
newTree.getDatabaseNodeByDatabasePath(pathList[i]).getAsMNode().getDatabaseSchema();
289-
Assert.assertEquals(i, storageGroupSchema.getSchemaReplicationFactor());
290-
Assert.assertEquals(i, storageGroupSchema.getDataReplicationFactor());
291-
Assert.assertEquals(i, storageGroupSchema.getTimePartitionInterval());
289+
Assert.assertEquals(i, databaseSchema.getSchemaReplicationFactor());
290+
Assert.assertEquals(i, databaseSchema.getDataReplicationFactor());
291+
Assert.assertEquals(i, databaseSchema.getTimePartitionInterval());
292292
assertEquals(
293293
i, newTree.getNodeWithAutoCreate(pathList[i].concatNode("a")).getSchemaTemplateId());
294294
}
@@ -327,16 +327,16 @@ public void testTableSerialization() throws Exception {
327327

328328
for (int i = 0; i < pathList.length; i++) {
329329
root.setStorageGroup(pathList[i]);
330-
final IDatabaseMNode<IConfigMNode> storageGroupMNode =
330+
final IDatabaseMNode<IConfigMNode> databaseMNode =
331331
root.getDatabaseNodeByDatabasePath(pathList[i]);
332-
storageGroupMNode
332+
databaseMNode
333333
.getAsMNode()
334334
.getDatabaseSchema()
335335
.setName(
336336
PathUtils.unQualifyDatabaseName(
337-
storageGroupMNode.getAsMNode().getDatabaseSchema().getName()));
338-
storageGroupMNode.getAsMNode().getDatabaseSchema().setDataReplicationFactor(i);
339-
storageGroupMNode.getAsMNode().getDatabaseSchema().setSchemaReplicationFactor(i);
337+
databaseMNode.getAsMNode().getDatabaseSchema().getName()));
338+
databaseMNode.getAsMNode().getDatabaseSchema().setDataReplicationFactor(i);
339+
databaseMNode.getAsMNode().getDatabaseSchema().setSchemaReplicationFactor(i);
340340
storageGroupMNode.getAsMNode().getDatabaseSchema().setTimePartitionInterval(i);
341341
storageGroupMNode.getAsMNode().getDatabaseSchema().setIsTableModel(true);
342342

0 commit comments

Comments
 (0)