This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch test_wal_sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/test_wal_sync by this push:
new 56eb9464af add more logs
56eb9464af is described below
commit 56eb9464af202e91c28f8525d1a389d300778723
Author: Jinrui.Zhang <[email protected]>
AuthorDate: Tue Jun 28 14:18:10 2022 +0800
add more logs
---
server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../org/apache/iotdb/db/mpp/plan/analyze/ClusterPartitionFetcher.java | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index d27da1e114..26ba351a27 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -896,7 +896,7 @@ public class IoTDBConfig {
* Cache size of partition cache in {@link
* org.apache.iotdb.db.mpp.plan.analyze.ClusterPartitionFetcher}
*/
- private int partitionCacheSize = 100000;
+ private int partitionCacheSize = 0;
/** Cache size of user and role */
private int authorCacheSize = 100;
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 ebfed56211..256c305d9e 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
@@ -278,6 +278,7 @@ public class ClusterPartitionFetcher implements
IPartitionFetcher {
configNodeClientManager.borrowClient(ConfigNodeInfo.partitionRegionId)) {
TStorageGroupSchemaResp storageGroupSchemaResp =
client.getMatchedStorageGroupSchemas(ROOT_PATH);
+ logger.info("fetch sg. target: {}",
storageGroupSchemaResp.storageGroupSchemaMap);
if (storageGroupSchemaResp.getStatus().getCode()
== TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
Set<String> storageGroupNames =