[prev in list] [next in list] [prev in thread] [next in thread]
List: hadoop-commits
Subject: git commit: YARN-2627. Added the info logs of attemptFailuresValidityInterval and number of previous
From: zjshen () apache ! org
Date: 2014-09-30 20:01:57
Message-ID: 38f61de4fab245cd8ce9e7054ab45bff () git ! apache ! org
[Download RAW message or body]
Repository: hadoop
Updated Branches:
refs/heads/branch-2.6 62d47e396 -> b19f668f5
YARN-2627. Added the info logs of attemptFailuresValidityInterval and number of \
previous failed attempts. Contributed by Xuan Gong.
(cherry picked from commit 9582a50176800433ad3fa8829a50c28b859812a3)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/b19f668f
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/b19f668f
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/b19f668f
Branch: refs/heads/branch-2.6
Commit: b19f668f5df12aa0b6d7fc42e481ba5d12f5e396
Parents: 62d47e3
Author: Zhijie Shen <zjshen@apache.org>
Authored: Tue Sep 30 12:57:45 2014 -0700
Committer: Zhijie Shen <zjshen@apache.org>
Committed: Tue Sep 30 13:01:13 2014 -0700
----------------------------------------------------------------------
hadoop-yarn-project/CHANGES.txt | 3 +++
.../yarn/server/resourcemanager/rmapp/RMAppImpl.java | 11 +++++++++++
2 files changed, 14 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/b19f668f/hadoop-yarn-project/CHANGES.txt
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt
index 4e62631..628f64f 100644
--- a/hadoop-yarn-project/CHANGES.txt
+++ b/hadoop-yarn-project/CHANGES.txt
@@ -238,6 +238,9 @@ Release 2.6.0 - UNRELEASED
YARN-1769. CapacityScheduler: Improve reservations (Thomas Graves via
jlowe)
+ YARN-2627. Added the info logs of attemptFailuresValidityInterval and number
+ of previous failed attempts. (Xuan Gong via zjshen)
+
OPTIMIZATIONS
BUG FIXES
http://git-wip-us.apache.org/repos/asf/hadoop/blob/b19f668f/hadoop-yarn-project/hadoop \
-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-res \
ourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java \
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanage \
r/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java \
index 0b8f321..eaef7d2 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcema \
nager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcema \
nager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java
@@ -376,6 +376,11 @@ public class RMAppImpl implements RMApp, Recoverable {
this.attemptFailuresValidityInterval =
submissionContext.getAttemptFailuresValidityInterval();
+ if (this.attemptFailuresValidityInterval > 0) {
+ LOG.info("The attemptFailuresValidityInterval for the application: "
+ + this.applicationId + " is " + this.attemptFailuresValidityInterval
+ + ".");
+ }
ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
this.readLock = lock.readLock();
@@ -1179,6 +1184,11 @@ public class RMAppImpl implements RMApp, Recoverable {
@Override
public RMAppState transition(RMAppImpl app, RMAppEvent event) {
int numberOfFailure = app.getNumFailedAppAttempts();
+ LOG.info("The number of failed attempts"
+ + (app.attemptFailuresValidityInterval > 0 ? " in previous "
+ + app.attemptFailuresValidityInterval + " milliseconds " : " ")
+ + "is " + numberOfFailure + ". The max attempts is "
+ + app.maxAppAttempts);
if (!app.submissionContext.getUnmanagedAM()
&& numberOfFailure < app.maxAppAttempts) {
boolean transferStateFromPreviousAttempt;
@@ -1293,4 +1303,5 @@ public class RMAppImpl implements RMApp, Recoverable {
public void setSystemClock(Clock clock) {
this.systemClock = clock;
}
+
}
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic