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 {