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 <[email protected]> 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()) {
