You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2021/08/20 05:21:21 UTC
[iotdb] 02/02: add log
This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a commit to branch fix_tsm_cache
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 327ffe872c7d05d455cf81ffaf4253fc314a9b78
Author: Alima777 <wx...@gmail.com>
AuthorDate: Fri Aug 20 13:20:15 2021 +0800
add log
---
.../java/org/apache/iotdb/db/engine/cache/ChunkCache.java | 14 ++++++++++----
1 file changed, 10 insertions(+), 4 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/cache/ChunkCache.java b/server/src/main/java/org/apache/iotdb/db/engine/cache/ChunkCache.java
index f419a82..6b3cdbf 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/cache/ChunkCache.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/cache/ChunkCache.java
@@ -63,10 +63,16 @@ public class ChunkCache {
.maximumWeight(MEMORY_THRESHOLD_IN_CHUNK_CACHE)
.weigher(
(Weigher<ChunkMetadata, Chunk>)
- (chunkMetadata, chunk) ->
- (int)
- (RamUsageEstimator.NUM_BYTES_OBJECT_REF
- + RamUsageEstimator.sizeOf(chunk)))
+ (chunkMetadata, chunk) -> {
+ int entrySize =
+ (int)
+ (RamUsageEstimator.NUM_BYTES_OBJECT_REF
+ + RamUsageEstimator.sizeOf(chunk));
+ if (entrySize > 1024 * 1024 * 10) {
+ logger.warn(String.format("Chunk size is %d over 10M", entrySize));
+ }
+ return entrySize;
+ })
.recordStats()
.build(
chunkMetadata -> {