This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 9dece729fa9 Imporve some log printing of Storage engine (#11829)
9dece729fa9 is described below
commit 9dece729fa93e391b4a485074a763d4d5e24276d
Author: Haonan <[email protected]>
AuthorDate: Wed Jan 3 17:33:47 2024 +0800
Imporve some log printing of Storage engine (#11829)
---
.../storageengine/dataregion/memtable/TsFileProcessor.java | 14 ++++++--------
.../db/storageengine/dataregion/wal/node/WALNode.java | 4 ++--
2 files changed, 8 insertions(+), 10 deletions(-)
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 1f11f696abb..54e9b42cca0 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
@@ -1346,14 +1346,12 @@ public class TsFileProcessor {
private void updateCompressionRatio() {
try {
double compressionRatio = ((double) totalMemTableSize) / writer.getPos();
- if (logger.isDebugEnabled()) {
- logger.debug(
- "The compression ratio of tsfile {} is {}, totalMemTableSize: {},
the file size: {}",
- writer.getFile().getAbsolutePath(),
- compressionRatio,
- totalMemTableSize,
- writer.getPos());
- }
+ logger.info(
+ "The compression ratio of tsfile {} is {}, totalMemTableSize: {},
the file size: {}",
+ writer.getFile().getAbsolutePath(),
+ String.format("%.2f", compressionRatio),
+ totalMemTableSize,
+ writer.getPos());
String dataRegionId = dataRegionInfo.getDataRegion().getDataRegionId();
WritingMetrics.getInstance()
.recordTsFileCompressionRatioOfFlushingMemTable(dataRegionId,
compressionRatio);
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALNode.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALNode.java
index 906f869e526..9501834f475 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALNode.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALNode.java
@@ -506,7 +506,7 @@ public class WALNode implements IWALNode {
identifier,
memTable.getMemTableId(),
tsFile,
- effectiveInfoRatio,
+ String.format("%.4f", effectiveInfoRatio),
config.getWalMinEffectiveInfoRatio(),
memTable.getTVListsRamCost());
}
@@ -573,7 +573,7 @@ public class WALNode implements IWALNode {
"WAL node-{} snapshots memTable-{} to wal files because
Effective information ratio {} is below wal min effective info ratio {},
memTable size is {}.",
identifier,
memTable.getMemTableId(),
- effectiveInfoRatio,
+ String.format("%.4f", effectiveInfoRatio),
config.getWalMinEffectiveInfoRatio(),
memTable.getTVListsRamCost());
WRITING_METRICS.recordMemTableRamWhenCauseSnapshot(