HDFS-16339. Show the threshold when mover threads quota is exceeded (#3689)
Reviewed-by: Viraj Jasani <vjasani@apache.org>
Reviewed-by: Hui Fei <ferhui@apache.org>
(cherry picked from commit 86705eda82
)
This commit is contained in:
parent
a13a03ec10
commit
b428d534fb
@ -1092,7 +1092,7 @@ public void copyBlock(final ExtendedBlock block,
|
||||
if (!dataXceiverServer.balanceThrottler.acquire()) { // not able to start
|
||||
String msg = "Not able to copy block " + block.getBlockId() + " " +
|
||||
"to " + peer.getRemoteAddressString() + " because threads " +
|
||||
"quota is exceeded.";
|
||||
"quota=" + dataXceiverServer.balanceThrottler.getMaxConcurrentMovers() + " is exceeded.";
|
||||
LOG.info(msg);
|
||||
sendResponse(ERROR, msg);
|
||||
return;
|
||||
@ -1166,7 +1166,7 @@ public void replaceBlock(final ExtendedBlock block,
|
||||
if (!dataXceiverServer.balanceThrottler.acquire()) { // not able to start
|
||||
String msg = "Not able to receive block " + block.getBlockId() +
|
||||
" from " + peer.getRemoteAddressString() + " because threads " +
|
||||
"quota is exceeded.";
|
||||
"quota=" + dataXceiverServer.balanceThrottler.getMaxConcurrentMovers() + " is exceeded.";
|
||||
LOG.warn(msg);
|
||||
sendResponse(ERROR, msg);
|
||||
return;
|
||||
|
Loading…
Reference in New Issue
Block a user