You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2023/07/31 13:26:26 UTC
[iotdb] 11/11: Bug fix
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch Computing-resource-balancing_cp
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ddd6c62bffcfe7fc5f2d8fe9991ab1d86d5dce15
Author: YongzaoDan <53...@qq.com>
AuthorDate: Mon Jul 31 20:50:28 2023 +0800
Bug fix
---
.../iotdb/confignode/manager/load/balancer/PartitionBalancer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/PartitionBalancer.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/PartitionBalancer.java
index bbac4510137..6bfa9ae0671 100644
--- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/PartitionBalancer.java
+++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/PartitionBalancer.java
@@ -131,10 +131,10 @@ public class PartitionBalancer {
counter.put(pair.getRight(), pair.getLeft().intValue());
}
+ DataPartitionTable dataPartitionTable = new DataPartitionTable();
DataPartitionPolicyTable allotTable = dataPartitionPolicyTableMap.get(database);
try {
allotTable.acquireLock();
- DataPartitionTable dataPartitionTable = new DataPartitionTable();
// Enumerate SeriesPartitionSlot
for (Map.Entry<TSeriesPartitionSlot, TTimeSlotList> seriesPartitionEntry :
unassignedPartitionSlotsMap.entrySet()) {