MAPREDUCE-6905. HADOOP_JOB_HISTORY_OPTS should be HADOOP_JOB_HISTORYSERVER_OPTS in mapred-config.sh. Contributed by LiXin Ge.
This commit is contained in:
parent
fa1aaee87b
commit
bf1f59937d
@ -294,8 +294,17 @@ private void createControlFile(FileSystem fs,
|
||||
int nrFiles
|
||||
) throws IOException {
|
||||
LOG.info("creating control file: "+nrBytes+" bytes, "+nrFiles+" files");
|
||||
|
||||
final int maxDirItems = config.getInt(
|
||||
DFSConfigKeys.DFS_NAMENODE_MAX_DIRECTORY_ITEMS_KEY,
|
||||
DFSConfigKeys.DFS_NAMENODE_MAX_DIRECTORY_ITEMS_DEFAULT);
|
||||
Path controlDir = getControlDir(config);
|
||||
|
||||
if (nrFiles > maxDirItems) {
|
||||
final String message = "The directory item limit of " + controlDir +
|
||||
" is exceeded: limit=" + maxDirItems + " items=" + nrFiles;
|
||||
throw new IOException(message);
|
||||
}
|
||||
|
||||
fs.delete(controlDir, true);
|
||||
|
||||
for(int i=0; i < nrFiles; i++) {
|
||||
@ -310,8 +319,9 @@ private void createControlFile(FileSystem fs,
|
||||
} catch(Exception e) {
|
||||
throw new IOException(e.getLocalizedMessage());
|
||||
} finally {
|
||||
if (writer != null)
|
||||
if (writer != null) {
|
||||
writer.close();
|
||||
}
|
||||
writer = null;
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user