This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new d7616ec22a HDDS-12135. Set RM default deadline to 12 minutes and
datanode offset to 6 minutes (#7747)
d7616ec22a is described below
commit d7616ec22a60e1f9ed9e2eea4ecdccd1a0c98bf1
Author: Stephen O'Donnell <[email protected]>
AuthorDate: Sun Jan 26 10:26:54 2025 +0000
HDDS-12135. Set RM default deadline to 12 minutes and datanode offset to 6
minutes (#7747)
---
.../hadoop/hdds/scm/container/replication/ReplicationManager.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/ReplicationManager.java
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/ReplicationManager.java
index d183c876e9..1675da0fa8 100644
---
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/ReplicationManager.java
+++
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/replication/ReplicationManager.java
@@ -1096,13 +1096,13 @@ public static class ReplicationManagerConfiguration
*/
@Config(key = "event.timeout",
type = ConfigType.TIME,
- defaultValue = "10m",
+ defaultValue = "12m",
reconfigurable = true,
tags = {SCM, OZONE},
description = "Timeout for the container replication/deletion commands
"
+ "sent to datanodes. After this timeout the command will be "
+ "retried.")
- private long eventTimeout = Duration.ofMinutes(10).toMillis();
+ private long eventTimeout = Duration.ofMinutes(12).toMillis();
public void setInterval(Duration interval) {
this.interval = interval;
}
@@ -1118,7 +1118,7 @@ public void setEventTimeout(Duration timeout) {
*/
@Config(key = "event.timeout.datanode.offset",
type = ConfigType.TIME,
- defaultValue = "30s",
+ defaultValue = "6m",
reconfigurable = true,
tags = {SCM, OZONE},
description = "The amount of time to subtract from "
@@ -1126,7 +1126,7 @@ public void setEventTimeout(Duration timeout) {
+ "datanodes which is less than the SCM timeout. This ensures "
+ "the datanodes will not process a command after SCM believes it "
+ "should have expired.")
- private long datanodeTimeoutOffset = Duration.ofSeconds(30).toMillis();
+ private long datanodeTimeoutOffset = Duration.ofMinutes(6).toMillis();
public long getDatanodeTimeoutOffset() {
return datanodeTimeoutOffset;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
