add logs when unexpected paths are found

apache · Mar 16, 2020 · f4428ed · f4428ed
1 parent 8014089
commit f4428ed
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/merge/task/MergeMultiChunkTask.java b/server/src/main/java/org/apache/iotdb/db/engine/merge/task/MergeMultiChunkTask.java
@@ -152,7 +152,6 @@ private void pathsMergeOneFile(int seqFileIdx, IPointReader[] unseqReaders)
     TsFileResource currTsFile = resource.getSeqFiles().get(seqFileIdx);
     String deviceId = currMergingPaths.get(0).getDevice();
     Long currDeviceMinTime = currTsFile.getStartTimeMap().get(deviceId);
-    //COMMENTS: is this correct? how about if there are other devices (in the currMergingPaths) that have unseq data?
     if (currDeviceMinTime == null) {
       return;
     }

diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriter.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriter.java
@@ -397,6 +397,7 @@ public void filterChunks(Map<Path, List<Long>> chunkStartTimes) {
     Map<Path, Integer> startTimeIdxes = new HashMap<>();
     chunkStartTimes.forEach((p, t) -> startTimeIdxes.put(p, 0));
 
+    boolean pathsShown = false;
     Iterator<ChunkGroupMetaData> chunkGroupMetaDataIterator = chunkGroupMetaDataList.iterator();
     while (chunkGroupMetaDataIterator.hasNext()) {
       ChunkGroupMetaData chunkGroupMetaData = chunkGroupMetaDataIterator.next();
@@ -410,6 +411,10 @@ public void filterChunks(Map<Path, List<Long>> chunkStartTimes) {
         Integer startTimeIdx = startTimeIdxes.get(path);
         if (startTimeIdx == null) {
           logger.error("Unexpected timeseries {} found in file {}", path, file);
+          if (!pathsShown) {
+            logger.error("Merged timeseries in file {} are {}", file, startTimeIdxes.keySet());
+            pathsShown = true;
+          }
           continue;
         }