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:32:02 UTC
[iotdb] 06/10: print dataPartitionQueryParams
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 <hh...@outlook.com>
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());