Apache/hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-16339. Show the threshold when mover threads quota is exceeded (#3689)

Browse Source 
Reviewed-by: Viraj Jasani <vjasani@apache.org>
Reviewed-by: Hui Fei <ferhui@apache.org>
(cherry picked from commit 86705eda82208b6b04551e637414d0d9d64a4173)
This commit is contained in:
litao 2021-11-26 18:52:14 +08:00 committed by Chao Sun
parent e449daccf4
commit 30f0629d6e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/DataXceiver.java
View File

@ -1092,7 +1092,7 @@ public void copyBlock(final ExtendedBlock block,
if (!dataXceiverServer.balanceThrottler.acquire()) { // not able to start if (!dataXceiverServer.balanceThrottler.acquire()) { // not able to start
String msg = "Not able to copy block " + block.getBlockId() + " " + String msg = "Not able to copy block " + block.getBlockId() + " " +
"to " + peer.getRemoteAddressString() + " because threads " + "to " + peer.getRemoteAddressString() + " because threads " +
"quota is exceeded."; "quota=" + dataXceiverServer.balanceThrottler.getMaxConcurrentMovers() + " is exceeded.";
LOG.info(msg); LOG.info(msg);
sendResponse(ERROR, msg); sendResponse(ERROR, msg);
return; return;
@ -1166,7 +1166,7 @@ public void replaceBlock(final ExtendedBlock block,
if (!dataXceiverServer.balanceThrottler.acquire()) { // not able to start if (!dataXceiverServer.balanceThrottler.acquire()) { // not able to start
String msg = "Not able to receive block " + block.getBlockId() + String msg = "Not able to receive block " + block.getBlockId() +
" from " + peer.getRemoteAddressString() + " because threads " + " from " + peer.getRemoteAddressString() + " because threads " +
"quota is exceeded."; "quota=" + dataXceiverServer.balanceThrottler.getMaxConcurrentMovers() + " is exceeded.";
LOG.warn(msg); LOG.warn(msg);
sendResponse(ERROR, msg); sendResponse(ERROR, msg);
return; return;