[iotdb] branch test_wal_sync updated: add more logs

[xingtanzjr]

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 d427ebd712 add more logs
d427ebd712 is described below

commit d427ebd7125b6f228423d2f4a12dda1632e32532
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Tue Jun 28 15:01:06 2022 +0800

    add more logs
---
 .../apache/iotdb/db/mpp/plan/analyze/ClusterPartitionFetcher.java    | 2 +-
 .../plan/execution/config/executor/ClusterConfigTaskExecutor.java    | 5 +++++
 2 files changed, 6 insertions(+), 1 deletion(-)

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 256c305d9e..edade58e54 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,7 +278,7 @@ public class ClusterPartitionFetcher implements 
IPartitionFetcher {
           
configNodeClientManager.borrowClient(ConfigNodeInfo.partitionRegionId)) {
         TStorageGroupSchemaResp storageGroupSchemaResp =
             client.getMatchedStorageGroupSchemas(ROOT_PATH);
-        logger.info("fetch sg. target: {}", 
storageGroupSchemaResp.storageGroupSchemaMap);
+        logger.info("fetch sg. target: {}", 
storageGroupSchemaResp.storageGroupSchemaMap.keySet());
         if (storageGroupSchemaResp.getStatus().getCode()
             == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
           Set<String> storageGroupNames =
diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
index 93c08bfb40..296580ad9a 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
@@ -88,6 +88,7 @@ public class ClusterConfigTaskExecutor implements 
IConfigTaskExecutor {
   @Override
   public SettableFuture<ConfigTaskResult> setStorageGroup(
       SetStorageGroupStatement setStorageGroupStatement) {
+    LOGGER.info("set storage group task. {}", 
setStorageGroupStatement.getStorageGroupPath());
     SettableFuture<ConfigTaskResult> future = SettableFuture.create();
     // Construct request using statement
     TStorageGroupSchema storageGroupSchema =
@@ -107,6 +108,10 @@ public class ClusterConfigTaskExecutor implements 
IConfigTaskExecutor {
       } else {
         future.set(new ConfigTaskResult(TSStatusCode.SUCCESS_STATUS));
       }
+      LOGGER.info(
+          "set storage group task. {}. Status: {}",
+          setStorageGroupStatement.getStorageGroupPath(),
+          tsStatus.code);
     } catch (TException | IOException e) {
       future.setException(e);
     }