diff --git a/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java b/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java index c643f59a82196..aaf27ff5f0282 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/flush/MemTableFlushTask.java @@ -85,10 +85,12 @@ public MemTableFlushTask(IMemTable memTable, RestorableTsFileIOWriter writer, St */ public void syncFlushMemTable() throws ExecutionException, InterruptedException { - LOGGER.info("The memTable size of SG {} is {}, the avg series points num in chunk is {} ", + LOGGER.info( + "The memTable size of SG {} is {}, the avg series points num in chunk is {}, total timeseries number is {}", storageGroup, memTable.memSize(), - memTable.getTotalPointsNum() / memTable.getSeriesNumber()); + memTable.getTotalPointsNum() / memTable.getSeriesNumber(), + memTable.getSeriesNumber()); long estimatedTemporaryMemSize = 0L; if (config.isEnableMemControl() && SystemInfo.getInstance().isEncodingFasterThanIo()) { diff --git a/server/src/main/java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java b/server/src/main/java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java index d504cbcebd7e7..f11f15899e5f0 100644 --- a/server/src/main/java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java +++ b/server/src/main/java/org/apache/iotdb/db/writelog/io/SingleFileLogReader.java @@ -91,7 +91,9 @@ public boolean hasNext() { batchLogReader = new BatchLogReader(ByteBuffer.wrap(buffer)); fileCorrupted = fileCorrupted || batchLogReader.isFileCorrupted(); } catch (Exception e) { - logger.error("Cannot read more PhysicalPlans from {} because", filepath, e); + logger.error( + "Cannot read more PhysicalPlans from {}, successfully read index is {}. The reason is", + idx, filepath, e); fileCorrupted = true; return false; } @@ -122,6 +124,7 @@ public void close() { public void open(File logFile) throws FileNotFoundException { close(); logStream = new DataInputStream(new BufferedInputStream(new FileInputStream(logFile))); + logger.info("open WAL file: {} size is {}", logFile.getName(), logFile.length()); this.filepath = logFile.getPath(); idx = 0; }