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