From eae0035a2d747184b51f25ac4c4e674347af28c4 Mon Sep 17 00:00:00 2001 From: Inigo Goiri Date: Mon, 28 Sep 2020 09:40:39 -0700 Subject: [PATCH] HDFS-15530. RBF: Fix typo in DFS_ROUTER_QUOTA_CACHE_UPDATE_INTERVAL var definition. Contributed by Sha Fanghao. --- .../hadoop/hdfs/server/federation/router/RBFConfigKeys.java | 4 ++-- .../server/federation/router/RouterQuotaUpdateService.java | 4 ++-- .../hadoop/hdfs/server/federation/router/TestRouterQuota.java | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RBFConfigKeys.java b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RBFConfigKeys.java index efd4a3aff6..ba3659e0bd 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RBFConfigKeys.java +++ b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RBFConfigKeys.java @@ -312,9 +312,9 @@ public class RBFConfigKeys extends CommonConfigurationKeysPublic { public static final String DFS_ROUTER_QUOTA_ENABLE = FEDERATION_ROUTER_PREFIX + "quota.enable"; public static final boolean DFS_ROUTER_QUOTA_ENABLED_DEFAULT = false; - public static final String DFS_ROUTER_QUOTA_CACHE_UPATE_INTERVAL = + public static final String DFS_ROUTER_QUOTA_CACHE_UPDATE_INTERVAL = FEDERATION_ROUTER_PREFIX + "quota-cache.update.interval"; - public static final long DFS_ROUTER_QUOTA_CACHE_UPATE_INTERVAL_DEFAULT = + public static final long DFS_ROUTER_QUOTA_CACHE_UPDATE_INTERVAL_DEFAULT = 60000; // HDFS Router security diff --git a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterQuotaUpdateService.java b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterQuotaUpdateService.java index 5ff03d1a1a..a4a7d9e9dd 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterQuotaUpdateService.java +++ b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterQuotaUpdateService.java @@ -70,8 +70,8 @@ public RouterQuotaUpdateService(final Router router) throws IOException { @Override protected void serviceInit(Configuration conf) throws Exception { this.setIntervalMs(conf.getTimeDuration( - RBFConfigKeys.DFS_ROUTER_QUOTA_CACHE_UPATE_INTERVAL, - RBFConfigKeys.DFS_ROUTER_QUOTA_CACHE_UPATE_INTERVAL_DEFAULT, + RBFConfigKeys.DFS_ROUTER_QUOTA_CACHE_UPDATE_INTERVAL, + RBFConfigKeys.DFS_ROUTER_QUOTA_CACHE_UPDATE_INTERVAL_DEFAULT, TimeUnit.MILLISECONDS)); super.serviceInit(conf); diff --git a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterQuota.java b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterQuota.java index 5326d48be2..a0fcc5512d 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterQuota.java +++ b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterQuota.java @@ -99,7 +99,7 @@ public void setUp() throws Exception { .quota() .rpc() .build(); - routerConf.set(RBFConfigKeys.DFS_ROUTER_QUOTA_CACHE_UPATE_INTERVAL, "2s"); + routerConf.set(RBFConfigKeys.DFS_ROUTER_QUOTA_CACHE_UPDATE_INTERVAL, "2s"); // override some hdfs settings that used in testing space quota Configuration hdfsConf = new Configuration(false);