This is an automated email from the ASF dual-hosted git repository.
rpuch pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new b19d0dc0f39 IGNITE-26205 Raise maxAllowedLagMillis default to 5
seconds (#6427)
b19d0dc0f39 is described below
commit b19d0dc0f3972ad54acba29808238de9a308f4b7
Author: Roman Puchkovskiy <[email protected]>
AuthorDate: Thu Aug 14 17:34:02 2025 +0400
IGNITE-26205 Raise maxAllowedLagMillis default to 5 seconds (#6427)
---
docs/_docs/administrators-guide/config/node-config.adoc | 12 ++++++------
.../ignite/internal/testframework/TestIgnitionManager.java | 5 ++++-
.../configuration/CriticalWorkersConfigurationSchema.java | 6 +++---
3 files changed, 13 insertions(+), 10 deletions(-)
diff --git a/docs/_docs/administrators-guide/config/node-config.adoc
b/docs/_docs/administrators-guide/config/node-config.adoc
index b9a3cbb49d6..44136492095 100644
--- a/docs/_docs/administrators-guide/config/node-config.adoc
+++ b/docs/_docs/administrators-guide/config/node-config.adoc
@@ -528,9 +528,9 @@ NOTE: Note that the property names are in `camelCase`.
"partitionsLogPath" : "",
"properties":[],
"criticalWorkers" : {
- "livenessCheckIntervalMillis" : 200,
- "maxAllowedLagMillis" : 500,
- "nettyThreadsHeartbeatIntervalMillis" : 100
+ "livenessCheckIntervalMillis" : 2000,
+ "maxAllowedLagMillis" : 5000,
+ "nettyThreadsHeartbeatIntervalMillis" : 1000
}
}
}
@@ -551,7 +551,7 @@ NOTE: Note that the property names are in `camelCase`.
|system.partitionsBasePath| The path data partitions are saved to on the node.
By default, partitions are stored in `{IGNITE_HOME}/work/partitions`. It is
recommended to only change this path on an empty node.| | Yes | Yes | Valid
absolute path.
|system.partitionsLogPath| The path RAFT log the partitions are stored at. By
default, this log is stored in `{system.partitionsBasePath}/log`. It is
recommended to only change this path on an empty node. | | Yes | Yes | Valid
absolute path.
|system.properties| System properties used by the Ignite components.| | Yes |
Yes | An array of properties.
-|system.criticalWorkers.livenessCheckIntervalMillis|200|Interval between
liveness checks (ms) performed by the critical worker infrastructure. | Yes |
Yes | 1 - inf (not greater than half of maxAllowedLagMillis)
-|system.criticalWorkers.maxAllowedLagMillis|500|Maximum allowed delay from the
last heartbeat to the current time (ms). If exceeded, the critical worker is
considered to be blocked.| Yes | No | 1 - inf (should be at least twice
livenessCheckInterval)
-|system.criticalWorkers.nettyThreadsHeartbeatIntervalMillis|100|Interval
between heartbeats used to update the Netty threads' heartbeat timestamps
(ms).| Yes | Yes | 1 - inf
+|system.criticalWorkers.livenessCheckIntervalMillis|2000|Interval between
liveness checks (ms) performed by the critical worker infrastructure. | Yes |
Yes | 1 - inf (not greater than half of maxAllowedLagMillis)
+|system.criticalWorkers.maxAllowedLagMillis|5000|Maximum allowed delay from
the last heartbeat to the current time (ms). If exceeded, the critical worker
is considered to be blocked.| Yes | No | 1 - inf (should be at least twice
livenessCheckInterval)
+|system.criticalWorkers.nettyThreadsHeartbeatIntervalMillis|1000|Interval
between heartbeats used to update the Netty threads' heartbeat timestamps
(ms).| Yes | Yes | 1 - inf
|======
diff --git
a/modules/runner/src/testFixtures/java/org/apache/ignite/internal/testframework/TestIgnitionManager.java
b/modules/runner/src/testFixtures/java/org/apache/ignite/internal/testframework/TestIgnitionManager.java
index acc78d7cdff..7504936d1cd 100644
---
a/modules/runner/src/testFixtures/java/org/apache/ignite/internal/testframework/TestIgnitionManager.java
+++
b/modules/runner/src/testFixtures/java/org/apache/ignite/internal/testframework/TestIgnitionManager.java
@@ -65,7 +65,10 @@ public class TestIgnitionManager {
/** Map with default node configuration values. */
private static final Map<String, String> DEFAULT_NODE_CONFIG =
Map.ofEntries(
entry("ignite.network.membership.scaleCube.metadataTimeoutMillis",
Integer.toString(DEFAULT_SCALECUBE_METADATA_TIMEOUT)),
- entry("ignite.system.properties.aipersistThrottling", "disabled")
+ entry("ignite.system.properties.aipersistThrottling", "disabled"),
+ entry("ignite.system.criticalWorkers.maxAllowedLagMillis", "500"),
+ entry("ignite.system.criticalWorkers.livenessCheckIntervalMillis",
"200"),
+
entry("ignite.system.criticalWorkers.nettyThreadsHeartbeatIntervalMillis",
"100")
);
/** Map of pre-configured by default storage profiles. */
diff --git
a/modules/workers/src/main/java/org/apache/ignite/internal/worker/configuration/CriticalWorkersConfigurationSchema.java
b/modules/workers/src/main/java/org/apache/ignite/internal/worker/configuration/CriticalWorkersConfigurationSchema.java
index c3cbd73833d..b81a0ea9b1c 100644
---
a/modules/workers/src/main/java/org/apache/ignite/internal/worker/configuration/CriticalWorkersConfigurationSchema.java
+++
b/modules/workers/src/main/java/org/apache/ignite/internal/worker/configuration/CriticalWorkersConfigurationSchema.java
@@ -27,9 +27,9 @@ import org.apache.ignite.configuration.validation.Range;
*/
@Config
public class CriticalWorkersConfigurationSchema {
- public static final int DEFAULT_LIVENESS_CHECK_INTERVAL_MILLIS = 200;
- public static final int DEFAULT_MAX_ALLOWED_LAG_MILLIS = 500;
- public static final int DEFAULT_NETTY_THREADS_HEARTBEAT_INTERVAL_MILLIS =
100;
+ public static final int DEFAULT_LIVENESS_CHECK_INTERVAL_MILLIS = 2000;
+ public static final int DEFAULT_MAX_ALLOWED_LAG_MILLIS = 5000;
+ public static final int DEFAULT_NETTY_THREADS_HEARTBEAT_INTERVAL_MILLIS =
1000;
/**
* Interval between liveness checks (ms) performed by the critical workers
infrastructure.