MAPREDUCE-6136. MRAppMaster doesn't shutdown file systems. Contributed by Brahma Reddy Battula.
This commit is contained in:
parent
8d88691d16
commit
348208014b
@ -414,6 +414,9 @@ Release 2.7.0 - UNRELEASED
|
|||||||
MAPREDUCE-6268. Fix typo in Task Attempt API's URL. (Ryu Kobayashi
|
MAPREDUCE-6268. Fix typo in Task Attempt API's URL. (Ryu Kobayashi
|
||||||
via ozawa)
|
via ozawa)
|
||||||
|
|
||||||
|
MAPREDUCE-6136. MRAppMaster doesn't shutdown file systems. (Brahma
|
||||||
|
Reddy Battula via ozawa)
|
||||||
|
|
||||||
Release 2.6.1 - UNRELEASED
|
Release 2.6.1 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
@ -1451,10 +1451,6 @@ public static void main(String[] args) {
|
|||||||
String jobUserName = System
|
String jobUserName = System
|
||||||
.getenv(ApplicationConstants.Environment.USER.name());
|
.getenv(ApplicationConstants.Environment.USER.name());
|
||||||
conf.set(MRJobConfig.USER_NAME, jobUserName);
|
conf.set(MRJobConfig.USER_NAME, jobUserName);
|
||||||
// Do not automatically close FileSystem objects so that in case of
|
|
||||||
// SIGTERM I have a chance to write out the job history. I'll be closing
|
|
||||||
// the objects myself.
|
|
||||||
conf.setBoolean("fs.automatic.close", false);
|
|
||||||
initAndStartAppMaster(appMaster, conf, jobUserName);
|
initAndStartAppMaster(appMaster, conf, jobUserName);
|
||||||
} catch (Throwable t) {
|
} catch (Throwable t) {
|
||||||
LOG.fatal("Error starting MRAppMaster", t);
|
LOG.fatal("Error starting MRAppMaster", t);
|
||||||
|
Loading…
Reference in New Issue
Block a user