You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/05/16 01:22:11 UTC

[iotdb] 02/04: opt

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch caLastOpt
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 8ce8f4501945e47fec48e40d4887f3bb680b5dc7
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Fri May 12 09:22:43 2023 +0800

    opt
---
 .../iotdb/db/mpp/plan/analyze/schema/ClusterSchemaFetcher.java      | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ClusterSchemaFetcher.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ClusterSchemaFetcher.java
index 53fa5ee1287..b1d57c6cbd1 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ClusterSchemaFetcher.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ClusterSchemaFetcher.java
@@ -39,6 +39,9 @@ import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
 import org.apache.iotdb.tsfile.utils.Pair;
 import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashSet;
@@ -50,6 +53,8 @@ import java.util.stream.IntStream;
 
 public class ClusterSchemaFetcher implements ISchemaFetcher {
 
+  private static final Logger LOGGER = LoggerFactory.getLogger(ClusterSchemaFetcher.class);
+
   private final IoTDBConfig config = IoTDBDescriptor.getInstance().getConfig();
 
   private final Coordinator coordinator = Coordinator.getInstance();
@@ -134,6 +139,7 @@ public class ClusterSchemaFetcher implements ISchemaFetcher {
         for (PartialPath fullPath : fullPathList) {
           cachedSchema = schemaCache.get(fullPath);
           if (cachedSchema.isEmpty()) {
+            LOGGER.info("Schema Cache Miss {}", fullPath.getFullPath());
             isAllCached = false;
             break;
           } else {