From 87cc2f1a1f9219bb90fe55a0e18721fba7d22e46 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=AB=A0=E9=94=A1=E5=B9=B3?= <40832063+zhangxiping1@users.noreply.github.com> Date: Tue, 16 Apr 2024 00:28:05 +0800 Subject: [PATCH] =?UTF-8?q?HDFS-17465.=20RBF:=20Use=20ProportionRouterRpcF?= =?UTF-8?q?airnessPolicyController=20get=20=E2=80=9C'ava.Lang.=20Error:=20?= =?UTF-8?q?Maximum=20permit=20count=20exceeded'=20(#6727)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../fairness/ProportionRouterRpcFairnessPolicyController.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/fairness/ProportionRouterRpcFairnessPolicyController.java b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/fairness/ProportionRouterRpcFairnessPolicyController.java index 71b5623901..8eeb251252 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/fairness/ProportionRouterRpcFairnessPolicyController.java +++ b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/fairness/ProportionRouterRpcFairnessPolicyController.java @@ -93,7 +93,8 @@ public boolean acquirePermit(String nsId) { public void releasePermit(String nsId) { if (contains(nsId)) { super.releasePermit(nsId); + } else { + super.releasePermit(DEFAULT_NS); } - super.releasePermit(DEFAULT_NS); } }