You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-commits@hadoop.apache.org by ma...@apache.org on 2011/09/20 02:02:22 UTC
svn commit: r1172910 - in
/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project: ./
hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/
hadoop-yarn/hadoop-yarn-serv...
Author: mahadev
Date: Tue Sep 20 00:02:22 2011
New Revision: 1172910
URL: http://svn.apache.org/viewvc?rev=1172910&view=rev
Log:
MAPREDUCE-3017. The Web UI shows FINISHED for killed/successful/failed jobs. (mahadev) - Merging r1172906 from trunk
Modified:
hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/CHANGES.txt
hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMApp.java
hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java
hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/RMAppAttempt.java
hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/RMAppAttemptImpl.java
hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/AppsBlock.java
hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/RmController.java
hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/applicationsmanager/MockAsm.java
hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/MockRMApp.java
Modified: hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/CHANGES.txt?rev=1172910&r1=1172909&r2=1172910&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/CHANGES.txt (original)
+++ hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/CHANGES.txt Tue Sep 20 00:02:22 2011
@@ -1331,6 +1331,9 @@ Release 0.23.0 - Unreleased
MAPREDUCE-3004. Fix ReduceTask to not assume 'local' mode in YARN. (Hitesh
Shah via acmurthy)
+ MAPREDUCE-3017. The Web UI shows FINISHED for killed/successful/failed jobs.
+ (mahadev)
+
Release 0.22.0 - Unreleased
INCOMPATIBLE CHANGES
Modified: hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMApp.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMApp.java?rev=1172910&r1=1172909&r2=1172910&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMApp.java (original)
+++ hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMApp.java Tue Sep 20 00:02:22 2011
@@ -18,40 +18,120 @@
package org.apache.hadoop.yarn.server.resourcemanager.rmapp;
+import org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest;
import org.apache.hadoop.yarn.api.records.ApplicationAttemptId;
import org.apache.hadoop.yarn.api.records.ApplicationId;
import org.apache.hadoop.yarn.api.records.ApplicationReport;
+import org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext;
import org.apache.hadoop.yarn.event.EventHandler;
+import org.apache.hadoop.yarn.server.resourcemanager.recovery.ApplicationsStore;
import org.apache.hadoop.yarn.server.resourcemanager.recovery.ApplicationsStore.ApplicationStore;
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt.RMAppAttempt;
+/**
+ * The read interface to an Application in the ResourceManager. Take a
+ * look at {@link RMAppImpl} for its implementation. This interface
+ * exposes methods to access various updates in application status/report.
+ */
public interface RMApp extends EventHandler<RMAppEvent>{
+ /**
+ * The application id for this {@link RMApp}.
+ * @return the {@link ApplicationId} for this {@link RMApp}.
+ */
ApplicationId getApplicationId();
+ /**
+ * The current state of the {@link RMApp}.
+ * @return the current state {@link RMAppState} for this application.
+ */
RMAppState getState();
+ /**
+ * The user who submitted this application.
+ * @return the user who submitted the application.
+ */
String getUser();
+ /**
+ * Progress of application.
+ * @return the progress of the {@link RMApp}.
+ */
float getProgress();
+ /**
+ * {@link RMApp} can have multiple application attempts {@link RMAppAttempt}.
+ * This method returns the {@link RMAppAttempt} corresponding to
+ * {@link ApplicationAttemptId}.
+ * @param appAttemptId the application attempt id
+ * @return the {@link RMAppAttempt} corresponding to the {@link ApplicationAttemptId}.
+ */
RMAppAttempt getRMAppAttempt(ApplicationAttemptId appAttemptId);
+ /**
+ * Each Application is submitted to a queue decided by {@link
+ * ApplicationSubmissionContext#setQueue(String)}.
+ * This method returns the queue to which an application was submitted.
+ * @return the queue to which the application was submitted to.
+ */
String getQueue();
+ /**
+ * The name of the application as set in {@link
+ * ApplicationSubmissionContext#setApplicationName(String)}.
+ * @return the name of the application.
+ */
String getName();
+ /**
+ * {@link RMApp} can have multiple application attempts {@link RMAppAttempt}.
+ * This method returns the current {@link RMAppAttempt}.
+ * @return the current {@link RMAppAttempt}
+ */
RMAppAttempt getCurrentAppAttempt();
+ /**
+ * To get the status of an application in the RM, this method can be used.
+ * @return the {@link ApplicationReport} detailing the status of the application.
+ */
ApplicationReport createAndGetApplicationReport();
+ /**
+ * Application level metadata is stored in {@link ApplicationStore} whicn
+ * can persist the information.
+ * @return the {@link ApplicationStore} for this {@link RMApp}.
+ */
ApplicationStore getApplicationStore();
+ /**
+ * The finish time of the {@link RMApp}
+ * @return the finish time of the application.,
+ */
long getFinishTime();
+ /**
+ * the start time of the application.
+ * @return the start time of the application.
+ */
long getStartTime();
+ /**
+ * The tracking url for the application master.
+ * @return the tracking url for the application master.
+ */
String getTrackingUrl();
+ /**
+ * the diagnostics information for the application master.
+ * @return the diagnostics information for the application master.
+ */
StringBuilder getDiagnostics();
+
+ /**
+ * The final state of the AM when unregistering as in
+ * {@link FinishApplicationMasterRequest#setFinalState(String)}.
+ * @return the final state of the AM as set in
+ * {@link FinishApplicationMasterRequest#setFinalState(String)}.
+ */
+ String getAMFinalState();
}
Modified: hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java?rev=1172910&r1=1172909&r2=1172910&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java (original)
+++ hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/RMAppImpl.java Tue Sep 20 00:02:22 2011
@@ -40,11 +40,10 @@ import org.apache.hadoop.yarn.api.record
import org.apache.hadoop.yarn.conf.YarnConfiguration;
import org.apache.hadoop.yarn.event.Dispatcher;
import org.apache.hadoop.yarn.server.resourcemanager.ApplicationMasterService;
-import org.apache.hadoop.yarn.server.resourcemanager.RMContext;
-import org.apache.hadoop.yarn.server.resourcemanager.recovery.ApplicationsStore.ApplicationStore;
import org.apache.hadoop.yarn.server.resourcemanager.RMAppManagerEvent;
import org.apache.hadoop.yarn.server.resourcemanager.RMAppManagerEventType;
-import org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt.AMLivelinessMonitor;
+import org.apache.hadoop.yarn.server.resourcemanager.RMContext;
+import org.apache.hadoop.yarn.server.resourcemanager.recovery.ApplicationsStore.ApplicationStore;
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt.RMAppAttempt;
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt.RMAppAttemptEvent;
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt.RMAppAttemptEventType;
@@ -195,6 +194,19 @@ public class RMAppImpl implements RMApp
}
@Override
+ public String getAMFinalState() {
+ this.readLock.lock();
+ try {
+ if (currentAttempt != null) {
+ return currentAttempt.getAMFinalState();
+ }
+ return "UNKNOWN";
+ } finally {
+ this.readLock.unlock();
+ }
+ }
+
+ @Override
public RMAppState getState() {
this.readLock.lock();
Modified: hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/RMAppAttempt.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/RMAppAttempt.java?rev=1172910&r1=1172909&r2=1172910&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/RMAppAttempt.java (original)
+++ hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/RMAppAttempt.java Tue Sep 20 00:02:22 2011
@@ -26,33 +26,103 @@ import org.apache.hadoop.yarn.api.record
import org.apache.hadoop.yarn.api.records.Container;
import org.apache.hadoop.yarn.api.records.ContainerStatus;
import org.apache.hadoop.yarn.api.records.NodeId;
+import org.apache.hadoop.yarn.conf.YarnConfiguration;
import org.apache.hadoop.yarn.event.EventHandler;
+import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMApp;
+/**
+ * Interface to an Application Attempt in the Resource Manager.
+ * A {@link RMApp} can have multiple app attempts based on
+ * {@link YarnConfiguration#RM_AM_MAX_RETRIES}. For specific
+ * implementation take a look at {@link RMAppAttemptImpl}.
+ */
public interface RMAppAttempt extends EventHandler<RMAppAttemptEvent>{
+ /**
+ * Get the application attempt id for this {@link RMAppAttempt}.
+ * @return the {@link ApplicationAttemptId} for this RM attempt.
+ */
ApplicationAttemptId getAppAttemptId();
+ /**
+ * The state of the {@link RMAppAttempt}.
+ * @return the state {@link RMAppAttemptState} of this {@link RMAppAttempt}
+ */
RMAppAttemptState getAppAttemptState();
-
+
+ /**
+ * The host on which the {@link RMAppAttempt} is running/ran on.
+ * @return the host on which the {@link RMAppAttempt} ran/is running on.
+ */
String getHost();
+ /**
+ * The rpc port of the {@link RMAppAttempt}.
+ * @return the rpc port of the {@link RMAppAttempt} to which the clients can connect
+ * to.
+ */
int getRpcPort();
+ /**
+ * The url at which the status of the application attempt can be accessed.
+ * @return the url at which the status of the attempt can be accessed.
+ */
String getTrackingUrl();
+ /**
+ * The token required by the clients to talk to the application attempt
+ * @return the token required by the clients to talk to the application attempt
+ */
String getClientToken();
+ /**
+ * Diagnostics information for the application attempt.
+ * @return diagnostics information for the application attempt.
+ */
StringBuilder getDiagnostics();
+ /**
+ * Progress for the application attempt.
+ * @return the progress for this {@link RMAppAttempt}
+ */
float getProgress();
+ /**
+ * The final state set by the AM.
+ * @return the final state that is set by the AM when unregistering itself.
+ */
+ String getAMFinalState();
+
+ /**
+ * Nodes on which the containers for this {@link RMAppAttempt} ran.
+ * @return the set of nodes that ran any containers from this {@link RMAppAttempt}
+ */
Set<NodeId> getRanNodes();
+ /**
+ * Return a list of the last set of finished containers, resetting the
+ * finished containers to empty.
+ * @return the list of just finished containers, re setting the finished containers.
+ */
List<ContainerStatus> pullJustFinishedContainers();
+ /**
+ * Return the list of last set of finished containers. This does not reset the
+ * finished containers.
+ * @return the list of just finished contianers, this does not reset the
+ * finished containers.
+ */
List<ContainerStatus> getJustFinishedContainers();
+ /**
+ * The container on which the Application Master is running.
+ * @return the {@link Container} on which the application master is running.
+ */
Container getMasterContainer();
+ /**
+ * The application submission context for this {@link RMAppAttempt}.
+ * @return the application submission context for this Application.
+ */
ApplicationSubmissionContext getSubmissionContext();
}
Modified: hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/RMAppAttemptImpl.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/RMAppAttemptImpl.java?rev=1172910&r1=1172909&r2=1172910&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/RMAppAttemptImpl.java (original)
+++ hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/attempt/RMAppAttemptImpl.java Tue Sep 20 00:02:22 2011
@@ -263,6 +263,16 @@ public class RMAppAttemptImpl implements
public ApplicationSubmissionContext getSubmissionContext() {
return this.submissionContext;
}
+
+ @Override
+ public String getAMFinalState() {
+ this.readLock.lock();
+ try {
+ return this.finalState;
+ } finally {
+ this.readLock.unlock();
+ }
+ }
@Override
public RMAppAttemptState getAppAttemptState() {
@@ -413,7 +423,8 @@ public class RMAppAttemptImpl implements
}
private static final class AttemptStartedTransition extends BaseTransition {
- @Override
+ @SuppressWarnings("unchecked")
+ @Override
public void transition(RMAppAttemptImpl appAttempt,
RMAppAttemptEvent event) {
Modified: hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/AppsBlock.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/AppsBlock.java?rev=1172910&r1=1172909&r2=1172910&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/AppsBlock.java (original)
+++ hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/AppsBlock.java Tue Sep 20 00:02:22 2011
@@ -23,6 +23,7 @@ import static org.apache.hadoop.yarn.web
import static org.apache.hadoop.yarn.webapp.view.JQueryUI._PROGRESSBAR_VALUE;
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMApp;
+import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMAppState;
import org.apache.hadoop.yarn.webapp.hamlet.Hamlet;
import org.apache.hadoop.yarn.webapp.hamlet.Hamlet.TABLE;
import org.apache.hadoop.yarn.webapp.hamlet.Hamlet.TBODY;
@@ -69,7 +70,8 @@ class AppsBlock extends HtmlBlock {
td(app.getUser().toString()).
td(app.getName().toString()).
td(app.getQueue().toString()).
- td(app.getState().toString()).
+ td(app.getState() == RMAppState.FINISHED ? app.getAMFinalState() :
+ app.getState().toString()).
td().
br().$title(percent)._(). // for sorting
div(_PROGRESSBAR).
Modified: hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/RmController.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/RmController.java?rev=1172910&r1=1172909&r2=1172910&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/RmController.java (original)
+++ hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/RmController.java Tue Sep 20 00:02:22 2011
@@ -29,6 +29,7 @@ import org.apache.hadoop.yarn.api.record
import org.apache.hadoop.yarn.server.resourcemanager.RMContext;
import org.apache.hadoop.yarn.server.resourcemanager.ResourceManager;
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMApp;
+import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMAppState;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.ResourceScheduler;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacityScheduler;
import org.apache.hadoop.yarn.util.Apps;
@@ -88,7 +89,9 @@ public class RmController extends Contro
ResponseInfo info = info("Application Overview").
_("User:", app.getUser()).
_("Name:", app.getName()).
- _("State:", app.getState()).
+ _("State:", (app.getState() == RMAppState.FINISHED ?
+ app.getAMFinalState() : app.getState().toString())
+ ).
_("Started:", Times.format(app.getStartTime())).
_("Elapsed:", StringUtils.formatTime(
Times.elapsed(app.getStartTime(), app.getFinishTime()))).
Modified: hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/applicationsmanager/MockAsm.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/applicationsmanager/MockAsm.java?rev=1172910&r1=1172909&r2=1172910&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/applicationsmanager/MockAsm.java (original)
+++ hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/applicationsmanager/MockAsm.java Tue Sep 20 00:02:22 2011
@@ -209,6 +209,11 @@ public abstract class MockAsm extends Mo
public void handle(RMAppEvent event) {
throw new UnsupportedOperationException("Not supported yet.");
}
+
+ @Override
+ public String getAMFinalState() {
+ throw new UnsupportedOperationException("Not supported yet.");
+ }
}
public static RMApp newApplication(int i) {
Modified: hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/MockRMApp.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/MockRMApp.java?rev=1172910&r1=1172909&r2=1172910&view=diff
==============================================================================
--- hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/MockRMApp.java (original)
+++ hadoop/common/branches/branch-0.23/hadoop-mapreduce-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/MockRMApp.java Tue Sep 20 00:02:22 2011
@@ -163,6 +163,11 @@ public class MockRMApp implements RMApp
}
public void handle(RMAppEvent event) {
+ }
+
+ @Override
+ public String getAMFinalState() {
+ return "UNKNOWN";
};
}