Merge branch 'trunk' into HDFS-6581
This commit is contained in:
commit
e4d29fda72
@ -2095,7 +2095,7 @@ public void testRMContainerAllocatorResendsRequestsOnRMRestart()
|
|||||||
conf.setInt(YarnConfiguration.RM_AM_MAX_ATTEMPTS,
|
conf.setInt(YarnConfiguration.RM_AM_MAX_ATTEMPTS,
|
||||||
YarnConfiguration.DEFAULT_RM_AM_MAX_ATTEMPTS);
|
YarnConfiguration.DEFAULT_RM_AM_MAX_ATTEMPTS);
|
||||||
conf.setBoolean(YarnConfiguration.RM_WORK_PRESERVING_RECOVERY_ENABLED, true);
|
conf.setBoolean(YarnConfiguration.RM_WORK_PRESERVING_RECOVERY_ENABLED, true);
|
||||||
|
conf.setLong(YarnConfiguration.RM_WORK_PRESERVING_RECOVERY_SCHEDULING_WAIT_MS, 0);
|
||||||
conf.setBoolean(MRJobConfig.MR_AM_JOB_NODE_BLACKLISTING_ENABLE, true);
|
conf.setBoolean(MRJobConfig.MR_AM_JOB_NODE_BLACKLISTING_ENABLE, true);
|
||||||
conf.setInt(MRJobConfig.MAX_TASK_FAILURES_PER_TRACKER, 1);
|
conf.setInt(MRJobConfig.MAX_TASK_FAILURES_PER_TRACKER, 1);
|
||||||
conf.setInt(
|
conf.setInt(
|
||||||
|
@ -397,6 +397,9 @@ Release 2.6.0 - UNRELEASED
|
|||||||
YARN-2563. Fixed YarnClient to call getTimeLineDelegationToken only if the
|
YARN-2563. Fixed YarnClient to call getTimeLineDelegationToken only if the
|
||||||
Token is not present. (Zhijie Shen via jianhe)
|
Token is not present. (Zhijie Shen via jianhe)
|
||||||
|
|
||||||
|
YARN-2568. Fixed the potential test failures due to race conditions when RM
|
||||||
|
work-preserving recovery is enabled. (Jian He via zjshen)
|
||||||
|
|
||||||
Release 2.5.1 - 2014-09-05
|
Release 2.5.1 - 2014-09-05
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
@ -84,6 +84,7 @@ public static void setup() throws Exception {
|
|||||||
conf.setInt(YarnConfiguration.RM_AM_MAX_ATTEMPTS,
|
conf.setInt(YarnConfiguration.RM_AM_MAX_ATTEMPTS,
|
||||||
YarnConfiguration.DEFAULT_RM_AM_MAX_ATTEMPTS);
|
YarnConfiguration.DEFAULT_RM_AM_MAX_ATTEMPTS);
|
||||||
conf.setBoolean(YarnConfiguration.RM_WORK_PRESERVING_RECOVERY_ENABLED, true);
|
conf.setBoolean(YarnConfiguration.RM_WORK_PRESERVING_RECOVERY_ENABLED, true);
|
||||||
|
conf.setLong(YarnConfiguration.RM_WORK_PRESERVING_RECOVERY_SCHEDULING_WAIT_MS, 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
// Test does major 6 steps verification.
|
// Test does major 6 steps verification.
|
||||||
|
@ -102,6 +102,7 @@ public void setup() throws UnknownHostException {
|
|||||||
conf.setClass(YarnConfiguration.RM_SCHEDULER, schedulerClass,
|
conf.setClass(YarnConfiguration.RM_SCHEDULER, schedulerClass,
|
||||||
ResourceScheduler.class);
|
ResourceScheduler.class);
|
||||||
conf.setBoolean(YarnConfiguration.RM_WORK_PRESERVING_RECOVERY_ENABLED, true);
|
conf.setBoolean(YarnConfiguration.RM_WORK_PRESERVING_RECOVERY_ENABLED, true);
|
||||||
|
conf.setLong(YarnConfiguration.RM_WORK_PRESERVING_RECOVERY_SCHEDULING_WAIT_MS, 0);
|
||||||
DefaultMetricsSystem.setMiniClusterMode(true);
|
DefaultMetricsSystem.setMiniClusterMode(true);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user