You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/10/18 12:11:30 UTC
[iotdb] branch IOTDB-4683 created (now 57c4362557)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch IOTDB-4683
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 57c4362557 [IOTDB-4683] Fix REJECT_THERSHOLD init error in SystemInfo
This branch includes the following new commits:
new 57c4362557 [IOTDB-4683] Fix REJECT_THERSHOLD init error in SystemInfo
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: [IOTDB-4683] Fix REJECT_THERSHOLD init error in SystemInfo
Posted by ha...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch IOTDB-4683
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 57c4362557ea7c91a1c040c6f1fec419365fc7b3
Author: HTHou <hh...@outlook.com>
AuthorDate: Tue Oct 18 20:11:12 2022 +0800
[IOTDB-4683] Fix REJECT_THERSHOLD init error in SystemInfo
---
server/src/main/java/org/apache/iotdb/db/rescon/SystemInfo.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/rescon/SystemInfo.java b/server/src/main/java/org/apache/iotdb/db/rescon/SystemInfo.java
index 710a523ec3..59b6defdd0 100644
--- a/server/src/main/java/org/apache/iotdb/db/rescon/SystemInfo.java
+++ b/server/src/main/java/org/apache/iotdb/db/rescon/SystemInfo.java
@@ -99,10 +99,11 @@ public class SystemInfo {
return true;
} else {
logger.info(
- "Change system to reject status. Triggered by: logical SG ({}), mem cost delta ({}), totalSgMemCost ({}).",
+ "Change system to reject status. Triggered by: logical SG ({}), mem cost delta ({}), totalSgMemCost ({}), REJECT_THERSHOLD ({})",
dataRegionInfo.getDataRegion().getStorageGroupName(),
delta,
- totalStorageGroupMemCost);
+ totalStorageGroupMemCost,
+ REJECT_THERSHOLD);
rejected = true;
if (chooseMemTablesToMarkFlush(tsFileProcessor)) {
if (totalStorageGroupMemCost < memorySizeForWrite) {
@@ -201,6 +202,8 @@ public class SystemInfo {
(long) (config.getAllocateMemoryForStorageEngine() * config.getWriteProportion());
memorySizeForCompaction =
(long) (config.getAllocateMemoryForStorageEngine() * config.getCompactionProportion());
+ FLUSH_THERSHOLD = memorySizeForWrite * config.getFlushProportion();
+ REJECT_THERSHOLD = memorySizeForWrite * config.getRejectProportion();
}
@TestOnly