big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDDS-1718. Increase Ratis Leader election timeout default. Contributed by Aravindan Vijayan & Siddharth Wagle. (#1062)

Browse Source
This commit is contained in:
Mukul Kumar Singh 2019-07-09 23:17:50 +05:30
parent 1dc58c5b04
commit 96d0555913
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-hdds/common/src/main/java/org/apache/hadoop/hdds/scm/ScmConfigKeys.java
View File

@ -147,7 +147,7 @@ public final class ScmConfigKeys {
"dfs.ratis.leader.election.minimum.timeout.duration"; "dfs.ratis.leader.election.minimum.timeout.duration";
public static final TimeDuration public static final TimeDuration
DFS_RATIS_LEADER_ELECTION_MINIMUM_TIMEOUT_DURATION_DEFAULT = DFS_RATIS_LEADER_ELECTION_MINIMUM_TIMEOUT_DURATION_DEFAULT =
TimeDuration.valueOf(1, TimeUnit.SECONDS); TimeDuration.valueOf(5, TimeUnit.SECONDS);
public static final String DFS_RATIS_SNAPSHOT_THRESHOLD_KEY = public static final String DFS_RATIS_SNAPSHOT_THRESHOLD_KEY =
"dfs.ratis.snapshot.threshold"; "dfs.ratis.snapshot.threshold";

4
hadoop-hdds/common/src/main/resources/ozone-default.xml
View File

@ -270,10 +270,10 @@
</property> </property>
<property> <property>
<name>dfs.ratis.leader.election.minimum.timeout.duration</name> <name>dfs.ratis.leader.election.minimum.timeout.duration</name>
<value>1s</value> <value>5s</value>
<tag>OZONE, RATIS, MANAGEMENT</tag> <tag>OZONE, RATIS, MANAGEMENT</tag>
<description>The minimum timeout duration for ratis leader election. <description>The minimum timeout duration for ratis leader election.
Default is 1s. Default is 5s.
</description> </description>
</property> </property>
<property> <property>

2
hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/TestCloseContainerCommandHandler.java
View File

@ -298,7 +298,7 @@ private Container createContainer(final Configuration conf,
maxOutstandingRequests, maxOutstandingRequests,
TimeDuration.valueOf(3, TimeUnit.SECONDS)); TimeDuration.valueOf(3, TimeUnit.SECONDS));
Assert.assertTrue(client.groupAdd(group, peer.getId()).isSuccess()); Assert.assertTrue(client.groupAdd(group, peer.getId()).isSuccess());
Thread.sleep(2000); Thread.sleep(10000);
final ContainerID containerId = ContainerID.valueof( final ContainerID containerId = ContainerID.valueof(
random.nextLong() & Long.MAX_VALUE); random.nextLong() & Long.MAX_VALUE);
ContainerProtos.ContainerCommandRequestProto.Builder request = ContainerProtos.ContainerCommandRequestProto.Builder request =