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

MAPREDUCE-6528. Memory leak for HistoryFileManager.getJobSummary(). Contributed by Junping Du 

(cherry picked from commit 6344b6a769)
This commit is contained in:
Jason Lowe 2015-10-30 15:31:38 +00:00
parent 055e11c53e
commit a7d8895b60
2 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-mapreduce-project/CHANGES.txt
View File

@ -390,6 +390,9 @@ Release 2.7.2 - UNRELEASED
avoid FileNotFoundException causing HistoryFileInfo into MOVE_FAILED state. avoid FileNotFoundException causing HistoryFileInfo into MOVE_FAILED state.
(zhihai xu via devaraj) (zhihai xu via devaraj)
MAPREDUCE-6528. Memory leak for HistoryFileManager.getJobSummary()
(Junping Du via jlowe)
Release 2.7.1 - 2015-07-06 Release 2.7.1 - 2015-07-06
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES
@ -620,6 +623,9 @@ Release 2.6.3 - UNRELEASED
avoid FileNotFoundException causing HistoryFileInfo into MOVE_FAILED state. avoid FileNotFoundException causing HistoryFileInfo into MOVE_FAILED state.
(zhihai xu via devaraj) (zhihai xu via devaraj)
MAPREDUCE-6528. Memory leak for HistoryFileManager.getJobSummary()
(Junping Du via jlowe)
Release 2.6.2 - 2015-10-21 Release 2.6.2 - 2015-10-21
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

11
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/main/java/org/apache/hadoop/mapreduce/v2/hs/HistoryFileManager.java
View File

@ -966,9 +966,16 @@ public class HistoryFileManager extends AbstractService {
private String getJobSummary(FileContext fc, Path path) throws IOException { private String getJobSummary(FileContext fc, Path path) throws IOException {
Path qPath = fc.makeQualified(path); Path qPath = fc.makeQualified(path);
FSDataInputStream in = fc.open(qPath); FSDataInputStream in = null;
String jobSummaryString = in.readUTF(); String jobSummaryString = null;
try {
in = fc.open(qPath);
jobSummaryString = in.readUTF();
} finally {
if (in != null) {
in.close(); in.close();
}
}
return jobSummaryString; return jobSummaryString;
} }