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

HDFS-16454:fix inconsistent comments in DataNode

This commit is contained in:
lujiefsi 2022-02-11 17:09:51 +08:00
parent 0e74f1e467
commit 539eab0dc8
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/DataNode.java
View File

@ -2227,14 +2227,14 @@ public class DataNode extends ReconfigurableBase
// wait reconfiguration thread, if any, to exit // wait reconfiguration thread, if any, to exit
shutdownReconfigurationTask(); shutdownReconfigurationTask();
LOG.info("Waiting up to 30 seconds for transfer threads to complete"); LOG.info("Waiting up to 15 seconds for transfer threads to complete");
HadoopExecutors.shutdown(this.xferService, LOG, 15L, TimeUnit.SECONDS); HadoopExecutors.shutdown(this.xferService, LOG, 15L, TimeUnit.SECONDS);
// wait for all data receiver threads to exit // wait for all data receiver threads to exit
if (this.threadGroup != null) { if (this.threadGroup != null) {
int sleepMs = 2; int sleepMs = 2;
while (true) { while (true) {
// When shutting down for restart, wait 2.5 seconds before forcing // When shutting down for restart, wait 1.0 seconds before forcing
// termination of receiver threads. // termination of receiver threads.
if (!this.shutdownForUpgrade || if (!this.shutdownForUpgrade ||
(this.shutdownForUpgrade && (Time.monotonicNow() - timeNotified (this.shutdownForUpgrade && (Time.monotonicNow() - timeNotified