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 2023/02/05 08:31:58 UTC
[iotdb] 02/10: print DataPartitionMap in datanode
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch geely_car_0205_confignode
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a6fe4094a7955ada3e5e83b0e8e0302d294a17a9
Author: HTHou <hh...@outlook.com>
AuthorDate: Tue Jan 31 15:50:45 2023 +0800
print DataPartitionMap in datanode
---
.../main/java/org/apache/iotdb/SessionExample.java | 63 +++-------------------
.../iotdb/commons/partition/DataPartition.java | 6 +++
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 2 +
3 files changed, 16 insertions(+), 55 deletions(-)
diff --git a/example/session/src/main/java/org/apache/iotdb/SessionExample.java b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
index 5d9fa09b7b..3032c2c47e 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
@@ -22,10 +22,8 @@ package org.apache.iotdb;
import org.apache.iotdb.isession.SessionDataSet;
import org.apache.iotdb.isession.SessionDataSet.DataIterator;
import org.apache.iotdb.isession.template.Template;
-import org.apache.iotdb.isession.util.Version;
import org.apache.iotdb.rpc.IoTDBConnectionException;
import org.apache.iotdb.rpc.StatementExecutionException;
-import org.apache.iotdb.rpc.TSStatusCode;
import org.apache.iotdb.session.Session;
import org.apache.iotdb.session.template.MeasurementNode;
import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType;
@@ -36,6 +34,9 @@ import org.apache.iotdb.tsfile.utils.BitMap;
import org.apache.iotdb.tsfile.write.record.Tablet;
import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
@@ -57,62 +58,14 @@ public class SessionExample {
private static final String ROOT_SG1_D1_S5 = "root.sg1.d1.s5";
private static final String ROOT_SG1_D1 = "root.sg1.d1";
private static final String LOCAL_HOST = "127.0.0.1";
+ private static final Logger LOGGER = LoggerFactory.getLogger(SessionExample.class);
public static void main(String[] args)
throws IoTDBConnectionException, StatementExecutionException {
- session =
- new Session.Builder()
- .host(LOCAL_HOST)
- .port(6667)
- .username("root")
- .password("root")
- .version(Version.V_0_13)
- .build();
- session.open(false);
-
- // set session fetchSize
- session.setFetchSize(10000);
-
- try {
- session.createDatabase("root.sg1");
- } catch (StatementExecutionException e) {
- if (e.getStatusCode() != TSStatusCode.PATH_ALREADY_EXIST.getStatusCode()) {
- throw e;
- }
- }
-
- // createTemplate();
- createTimeseries();
- createMultiTimeseries();
- insertRecord();
- insertTablet();
- // insertTabletWithNullValues();
- // insertTablets();
- // insertRecords();
- // insertText();
- // selectInto();
- // createAndDropContinuousQueries();
- // nonQuery();
- // query();
- // queryWithTimeout();
- // rawDataQuery();
- // lastDataQuery();
- // queryByIterator();
- // deleteData();
- // deleteTimeseries();
- // setTimeout();
-
- sessionEnableRedirect = new Session(LOCAL_HOST, 6667, "root", "root");
- sessionEnableRedirect.setEnableQueryRedirection(true);
- sessionEnableRedirect.open(false);
-
- // set session fetchSize
- sessionEnableRedirect.setFetchSize(10000);
-
- insertRecord4Redirect();
- query4Redirect();
- sessionEnableRedirect.close();
- session.close();
+ Map<String, Map<String, String>> map = new HashMap<>();
+ Map<String, String> map2 = new HashMap<>();
+ map.put("s1", new HashMap<>());
+ LOGGER.info("map is {}", map);
}
private static void createAndDropContinuousQueries()
diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java b/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
index 37df4c8aa2..073a5dbe9b 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java
@@ -23,6 +23,9 @@ import org.apache.iotdb.common.rpc.thrift.TSeriesPartitionSlot;
import org.apache.iotdb.common.rpc.thrift.TTimePartitionSlot;
import org.apache.iotdb.commons.utils.PathUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
@@ -33,6 +36,8 @@ import java.util.stream.Collectors;
// TODO: Remove this class
public class DataPartition extends Partition {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(DataPartition.class);
public static final TRegionReplicaSet NOT_ASSIGNED = new TRegionReplicaSet();
// Map<StorageGroup, Map<TSeriesPartitionSlot, Map<TTimePartitionSlot, List<TRegionMessage>>>>
private Map<String, Map<TSeriesPartitionSlot, Map<TTimePartitionSlot, List<TRegionReplicaSet>>>>
@@ -132,6 +137,7 @@ public class DataPartition extends Partition {
dataBasePartitionMap.get(seriesPartitionSlot);
List<TRegionReplicaSet> regions = slotReplicaSetMap.get(timePartitionSlot);
if (regions == null || regions.isEmpty()) {
+ LOGGER.error("DatabasePartitionMap is {}", dataBasePartitionMap);
throw new RuntimeException(
String.format(
"region is %s, device: %s, timeSlot: %s", regions, deviceName, timePartitionSlot));
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterPartitionFetcher.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterPartitionFetcher.java
index 029c878114..16c49f7353 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterPartitionFetcher.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterPartitionFetcher.java
@@ -267,6 +267,8 @@ public class ClusterPartitionFetcher implements IPartitionFetcher {
if (dataPartitionTableResp.getStatus().getCode()
== TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
dataPartition = parseDataPartitionResp(dataPartitionTableResp);
+ logger.error(
+ "DataPartitionMap from Confignode is {}", dataPartition.getDataPartitionMap());
partitionCache.updateDataPartitionCache(dataPartitionTableResp.getDataPartitionTable());
} else {
throw new RuntimeException(