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 b6b295da89df92c827abbee033eccdc9fd61b8d6 Author: HTHou <[email protected]> AuthorDate: Tue Jan 31 16:42:00 2023 +0800 print dataPartitionQueryParams --- .../iotdb/commons/partition/DataPartitionQueryParam.java | 11 +++++++++++ .../iotdb/db/mpp/plan/analyze/ClusterPartitionFetcher.java | 1 + 2 files changed, 12 insertions(+) diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartitionQueryParam.java b/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartitionQueryParam.java index 4ed3cd8dc4..533b98db63 100644 --- a/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartitionQueryParam.java +++ b/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartitionQueryParam.java @@ -86,4 +86,15 @@ public class DataPartitionQueryParam { public void setNeedRightAll(boolean needRightAll) { this.needRightAll = needRightAll; } + + @Override + public String toString() { + return "DataPartitionQueryParam{" + + "devicePath='" + + devicePath + + '\'' + + ", timePartitionSlotList=" + + timePartitionSlotList + + '}'; + } } 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 16c49f7353..001938939b 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,7 @@ public class ClusterPartitionFetcher implements IPartitionFetcher { if (dataPartitionTableResp.getStatus().getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) { dataPartition = parseDataPartitionResp(dataPartitionTableResp); + logger.error("dataPartitionQueryParams is {}", dataPartitionQueryParams); logger.error( "DataPartitionMap from Confignode is {}", dataPartition.getDataPartitionMap()); partitionCache.updateDataPartitionCache(dataPartitionTableResp.getDataPartitionTable());
