big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-3048. Small race in BlockManager#close. Contributed by Andy Isaacson

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1373664 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Eli Collins 2012-08-15 22:43:01 +00:00
parent b05c70bd96
commit f75deca0f9
2 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt
View File

@ -614,6 +614,8 @@ Branch-2 ( Unreleased changes )
header when offset is specified and length is omitted. header when offset is specified and length is omitted.
(Ravi Prakash via szetszwo) (Ravi Prakash via szetszwo)
HDFS-3048. Small race in BlockManager#close. (Andy Isaacson via eli)
BREAKDOWN OF HDFS-3042 SUBTASKS BREAKDOWN OF HDFS-3042 SUBTASKS
HDFS-2185. HDFS portion of ZK-based FailoverController (todd) HDFS-2185. HDFS portion of ZK-based FailoverController (todd)

9
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/BlockManager.java
View File

@ -373,10 +373,17 @@ public void activate(Configuration conf) {
} }
public void close() { public void close() {
try {
if (replicationThread != null) {
replicationThread.interrupt();
replicationThread.join(3000);
}
} catch (InterruptedException ie) {
} finally {
if (pendingReplications != null) pendingReplications.stop(); if (pendingReplications != null) pendingReplications.stop();
blocksMap.close(); blocksMap.close();
datanodeManager.close(); datanodeManager.close();
if (replicationThread != null) replicationThread.interrupt(); }
} }
/** @return the datanodeManager */ /** @return the datanodeManager */