Skip to content

Commit

Permalink
done
Browse files Browse the repository at this point in the history
  • Loading branch information
liyuheng55555 committed Sep 27, 2024
1 parent cd3e8af commit 254d9b4
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@
/** Internal cleaner that removes the completed procedure results after a TTL. */
public class CompletedProcedureRecycler<Env> extends InternalProcedure<Env> {
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<Long, CompletedProcedureContainer<Env>> completed;
private final IProcedureStore<Env> store;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 254d9b4

Please sign in to comment.