diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java index 2819d0a4a0016..84b61aca712e3 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java @@ -2359,16 +2359,6 @@ protected int executeCompaction() { } } if (summary.hasSubmitTask()) { - logger.info( - "[CompactionScheduler][{}] selected sequence InnerSpaceCompactionTask num is {}," - + " selected unsequence InnerSpaceCompactionTask num is {}," - + " selected CrossSpaceCompactionTask num is {}," - + " selected InsertionCrossSpaceCompactionTask num is {}", - dataRegionId, - summary.getSubmitSeqInnerSpaceCompactionTaskNum(), - summary.getSubmitUnseqInnerSpaceCompactionTaskNum(), - summary.getSubmitCrossSpaceCompactionTaskNum(), - summary.getSubmitInsertionCrossSpaceCompactionTaskNum()); CompactionMetrics.getInstance().updateCompactionTaskSelectionNum(summary); } return trySubmitCount; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/CompressionRatio.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/CompressionRatio.java index dfc37ba428e3c..5d6c40e148755 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/CompressionRatio.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/CompressionRatio.java @@ -95,9 +95,6 @@ public synchronized void updateRatio(long memorySize, long diskSize) throws IOEx String.format( Locale.ENGLISH, RATIO_FILE_PATH_FORMAT, totalMemorySize.get(), totalDiskSize)); persist(oldFile, newFile); - if (LOGGER.isDebugEnabled()) { - LOGGER.debug("Compression ratio is {}", (double) totalMemorySize.get() / totalDiskSize); - } } /** Get the average compression ratio for all closed files */ diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/MemTableFlushTask.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/MemTableFlushTask.java index 454702e72f3dd..46c919835a804 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/MemTableFlushTask.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/flush/MemTableFlushTask.java @@ -110,14 +110,6 @@ public void syncFlushMemTable() throws ExecutionException, InterruptedException memTable.getSeriesNumber() == 0 ? 0 : memTable.getTotalPointsNum() / memTable.getSeriesNumber(); - if (LOGGER.isDebugEnabled()) { - LOGGER.debug( - "The memTable size of SG {} is {}, the avg series points num in chunk is {}, total timeseries number is {}", - storageGroup, - memTable.memSize(), - avgSeriesPointsNum, - memTable.getSeriesNumber()); - } WRITING_METRICS.recordFlushingMemTableStatus( storageGroup, memTable.memSize(), @@ -215,14 +207,6 @@ public void syncFlushMemTable() throws ExecutionException, InterruptedException MetricLevel.CORE, Tag.NAME.toString(), "flush"); - - if (LOGGER.isDebugEnabled()) { - LOGGER.debug( - "Database {} memtable {} flushing a memtable has finished! Time consumption: {}ms", - storageGroup, - memTable, - System.currentTimeMillis() - start); - } } /** encoding task (second task of pipeline) */ @@ -288,14 +272,6 @@ public void run() { } recordFlushPointsMetric(); - - if (LOGGER.isDebugEnabled()) { - LOGGER.debug( - "Database {}, flushing memtable {} into disk: Encoding data cost " + "{} ms.", - storageGroup, - writer.getFile().getName(), - memSerializeTime); - } WRITING_METRICS.recordFlushCost(WritingMetrics.FLUSH_STAGE_ENCODING, memSerializeTime); } }; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java index 54e9b42cca06c..33d160c3c3708 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java @@ -792,12 +792,6 @@ public boolean shouldFlush() { return false; } if (workMemTable.shouldFlush()) { - if (logger.isDebugEnabled()) { - logger.debug( - "The memtable size {} of tsfile {} reaches the mem control threshold", - workMemTable.memSize(), - tsFileResource.getTsFile().getAbsolutePath()); - } return true; } if (!enableMemControl && workMemTable.memSize() >= getMemtableSizeThresholdBasedOnSeriesNum()) { @@ -873,9 +867,9 @@ public Future asyncClose() { FLUSH_QUERY_WRITE_LOCKED, storageGroupName, tsFileResource.getTsFile().getName()); } try { - if (logger.isInfoEnabled()) { + if (logger.isDebugEnabled()) { if (workMemTable != null) { - logger.info( + logger.debug( "{}: flush a working memtable in async close tsfile {}, memtable size: {}, tsfile " + "size: {}, plan index: [{}, {}], progress index: {}", storageGroupName, @@ -886,7 +880,7 @@ public Future asyncClose() { workMemTable.getMaxPlanIndex(), tsFileResource.getMaxProgressIndex()); } else { - logger.info( + logger.debug( "{}: flush a NotifyFlushMemTable in async close tsfile {}, tsfile size: {}", storageGroupName, tsFileResource.getTsFile().getAbsolutePath(), diff --git a/iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriter.java b/iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriter.java index 12b79a9fc80fe..658a16deda68a 100644 --- a/iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriter.java +++ b/iotdb-core/tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriter.java @@ -321,7 +321,6 @@ public void endCurrentChunk() { */ @SuppressWarnings("squid:S3776") // Suppress high Cognitive Complexity warning public void endFile() throws IOException { - long startTime = System.currentTimeMillis(); checkInMemoryPathCount(); readChunkMetadataAndConstructIndexTree(); @@ -348,8 +347,6 @@ public void endFile() throws IOException { } } canWrite = false; - long cost = System.currentTimeMillis() - startTime; - logger.debug("Time for flushing metadata is {} ms", cost); } private void checkInMemoryPathCount() {