From 254d9b440c40fe562abf3639b822fcf484ae936c Mon Sep 17 00:00:00 2001 From: liyuheng Date: Fri, 27 Sep 2024 14:50:23 +0800 Subject: [PATCH] done --- .../java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java | 2 +- .../iotdb/confignode/procedure/CompletedProcedureRecycler.java | 2 +- .../assembly/resources/conf/iotdb-system.properties.template | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java index 3689e25a4551..78935778b66d 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java @@ -159,7 +159,7 @@ public class ConfigNodeConfig { systemDir + File.separator + "pipe" + File.separator + "receiver"; /** Procedure Evict ttl. */ - private int procedureCompletedEvictTTL = 800; + private int procedureCompletedEvictTTL = 60; /** Procedure completed clean interval. */ private int procedureCompletedCleanInterval = 30; diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/CompletedProcedureRecycler.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/CompletedProcedureRecycler.java index ccf3afeb4e64..cea15a1bfb68 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/CompletedProcedureRecycler.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/CompletedProcedureRecycler.java @@ -31,7 +31,7 @@ /** Internal cleaner that removes the completed procedure results after a TTL. */ public class CompletedProcedureRecycler extends InternalProcedure { private static final Logger LOG = LoggerFactory.getLogger(CompletedProcedureRecycler.class); - private static final int DEFAULT_BATCH_SIZE = 32; + private static final int DEFAULT_BATCH_SIZE = 8; private final long evictTTL; private final Map> completed; private final IProcedureStore store; diff --git a/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template b/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template index 92dd2ce10b5b..deedd001186f 100644 --- a/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template +++ b/iotdb-core/node-commons/src/assembly/resources/conf/iotdb-system.properties.template @@ -1843,7 +1843,7 @@ procedure_completed_clean_interval=30 # Default ttl of completed procedure, time unit is second # effectiveMode: restart # Datatype: int -procedure_completed_evict_ttl=800 +procedure_completed_evict_ttl=60 #################### ### MQTT Broker Configuration