HDFS-15350. Set dfs.client.failover.random.order to true as default. (#2008)

This commit is contained in:
Takanobu Asanuma 2020-05-12 23:04:03 +09:00 committed by GitHub
parent 8dad38c0be
commit 928b81a533
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 2 deletions

View File

@ -343,7 +343,7 @@ public interface HdfsClientConfigKeys {
PREFIX + "connection.retries.on.timeouts"; PREFIX + "connection.retries.on.timeouts";
int CONNECTION_RETRIES_ON_SOCKET_TIMEOUTS_DEFAULT = 0; int CONNECTION_RETRIES_ON_SOCKET_TIMEOUTS_DEFAULT = 0;
String RANDOM_ORDER = PREFIX + "random.order"; String RANDOM_ORDER = PREFIX + "random.order";
boolean RANDOM_ORDER_DEFAULT = false; boolean RANDOM_ORDER_DEFAULT = true;
String RESOLVE_ADDRESS_NEEDED_KEY = PREFIX + "resolve-needed"; String RESOLVE_ADDRESS_NEEDED_KEY = PREFIX + "resolve-needed";
boolean RESOLVE_ADDRESS_NEEDED_DEFAULT = false; boolean RESOLVE_ADDRESS_NEEDED_DEFAULT = false;
String RESOLVE_SERVICE_KEY = PREFIX + "resolver.impl"; String RESOLVE_SERVICE_KEY = PREFIX + "resolver.impl";

View File

@ -4070,7 +4070,7 @@
<property> <property>
<name>dfs.client.failover.random.order</name> <name>dfs.client.failover.random.order</name>
<value>false</value> <value>true</value>
<description> <description>
Determines if the failover proxies are picked in random order instead of the Determines if the failover proxies are picked in random order instead of the
configured order. Random order may be enabled for better load balancing configured order. Random order may be enabled for better load balancing

View File

@ -78,6 +78,7 @@ public class TestObserverReadProxyProvider {
// transition observer back and forth // transition observer back and forth
conf.setTimeDuration( conf.setTimeDuration(
OBSERVER_PROBE_RETRY_PERIOD_KEY, 0, TimeUnit.MILLISECONDS); OBSERVER_PROBE_RETRY_PERIOD_KEY, 0, TimeUnit.MILLISECONDS);
conf.setBoolean(HdfsClientConfigKeys.Failover.RANDOM_ORDER, false);
} }
private void setupProxyProvider(int namenodeCount) throws Exception { private void setupProxyProvider(int namenodeCount) throws Exception {