|
@@ -417,7 +417,7 @@ public interface MRJobConfig {
|
|
|
/** How often the AM should send heartbeats to the RM.*/
|
|
|
public static final String MR_AM_TO_RM_HEARTBEAT_INTERVAL_MS =
|
|
|
MR_AM_PREFIX + "scheduler.heartbeat.interval-ms";
|
|
|
- public static final int DEFAULT_MR_AM_TO_RM_HEARTBEAT_INTERVAL_MS = 2000;
|
|
|
+ public static final int DEFAULT_MR_AM_TO_RM_HEARTBEAT_INTERVAL_MS = 1000;
|
|
|
|
|
|
/**
|
|
|
* If contact with RM is lost, the AM will wait MR_AM_TO_RM_WAIT_INTERVAL_MS
|