You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/11/28 10:44:52 UTC
[iotdb] branch QueryDataPartionOpt updated: config node changing
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch QueryDataPartionOpt
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/QueryDataPartionOpt by this push:
new 2306b9db5e config node changing
2306b9db5e is described below
commit 2306b9db5e2caf43885f8c2b963eb8677435977b
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Mon Nov 28 18:44:41 2022 +0800
config node changing
---
.../org/apache/iotdb/confignode/manager/ConfigManager.java | 7 ++++++-
.../consensus/request/ConfigPhysicalPlanSerDeTest.java | 10 ++++++++--
.../apache/iotdb/confignode/it/utils/ConfigNodeTestUtils.java | 5 ++++-
3 files changed, 18 insertions(+), 4 deletions(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
index 46ddf886f6..532a8fffe1 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java
@@ -1381,7 +1381,12 @@ public class ConfigManager implements IManager {
schemaPartitionTable.forEach(
(key, value) -> {
Map<TSeriesPartitionSlot, TTimePartitionSlotList> slotListMap = new HashMap<>();
- value.keySet().forEach(slot -> slotListMap.put(slot, new TTimePartitionSlotList()));
+ value
+ .keySet()
+ .forEach(
+ slot ->
+ slotListMap.put(
+ slot, new TTimePartitionSlotList(Collections.emptyList(), true, true)));
partitionSlotsMap.put(key, slotListMap);
});
diff --git a/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java b/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
index 4fb3b05204..b2e1d78a55 100644
--- a/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
+++ b/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
@@ -442,7 +442,10 @@ public class ConfigPhysicalPlanSerDeTest {
.get(storageGroup)
.put(
seriesPartitionSlot,
- new TTimePartitionSlotList().setTimePartitionSlots(new ArrayList<>()));
+ new TTimePartitionSlotList()
+ .setTimePartitionSlots(new ArrayList<>())
+ .setNeedLeftAll(true)
+ .setNeedRightAll(true));
partitionSlotsMap
.get(storageGroup)
.get(seriesPartitionSlot)
@@ -468,7 +471,10 @@ public class ConfigPhysicalPlanSerDeTest {
.get(storageGroup)
.put(
seriesPartitionSlot,
- new TTimePartitionSlotList().setTimePartitionSlots(new ArrayList<>()));
+ new TTimePartitionSlotList()
+ .setTimePartitionSlots(new ArrayList<>())
+ .setNeedLeftAll(true)
+ .setNeedRightAll(true));
partitionSlotsMap
.get(storageGroup)
.get(seriesPartitionSlot)
diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/utils/ConfigNodeTestUtils.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/utils/ConfigNodeTestUtils.java
index 6d882923fb..4545a8bf33 100644
--- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/utils/ConfigNodeTestUtils.java
+++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/utils/ConfigNodeTestUtils.java
@@ -138,7 +138,10 @@ public class ConfigNodeTestUtils {
.get(storageGroup)
.put(
seriesPartitionSlot,
- new TTimePartitionSlotList().setTimePartitionSlots(new ArrayList<>()));
+ new TTimePartitionSlotList()
+ .setTimePartitionSlots(new ArrayList<>())
+ .setNeedLeftAll(true)
+ .setNeedRightAll(true));
for (long j = timeSlotStart; j < timeSlotEnd; j++) {
TTimePartitionSlot timePartitionSlot = new TTimePartitionSlot(j * timePartitionInterval);
result