tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hit...@apache.org
Subject git commit: TEZ-321. Fix build break due to changes from YARN-875. (hitesh)
Date Thu, 25 Jul 2013 18:40:07 GMT
Updated Branches:
  refs/heads/master 7995dad7a -> f2460aff1


TEZ-321. Fix build break due to changes from YARN-875. (hitesh)


Project: http://git-wip-us.apache.org/repos/asf/incubator-tez/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tez/commit/f2460aff
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tez/tree/f2460aff
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tez/diff/f2460aff

Branch: refs/heads/master
Commit: f2460aff15fe1f0201f136e870b262b15f929b52
Parents: 7995dad
Author: Hitesh Shah <hitesh@apache.org>
Authored: Thu Jul 25 11:39:53 2013 -0700
Committer: Hitesh Shah <hitesh@apache.org>
Committed: Thu Jul 25 11:39:53 2013 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/tez/dag/app/rm/TaskScheduler.java   | 8 ++++----
 .../org/apache/tez/dag/app/rm/TaskSchedulerEventHandler.java | 2 +-
 2 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/f2460aff/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskScheduler.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskScheduler.java b/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskScheduler.java
index a4a417f..1f62a18 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskScheduler.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskScheduler.java
@@ -94,7 +94,7 @@ public class TaskScheduler extends AbstractService
                                 Resource maxContainerCapability,
                                 Map<ApplicationAccessType, String> appAcls
                                 );
-    public void onError(Exception e);
+    public void onError(Throwable t);
     public float getProgress();
     public AppFinalStatus getFinalAppStatus();
   }
@@ -372,11 +372,11 @@ public class TaskScheduler extends AbstractService
   }
 
   @Override
-  public void onError(Exception e) {
+  public void onError(Throwable t) {
     if(isStopped) {
       return;
     }
-    appClient.onError(e);
+    appClient.onError(t);
   }
   
   public synchronized Resource getTotalResources() {
@@ -587,5 +587,5 @@ public class TaskScheduler extends AbstractService
   private boolean isHigherPriority(Priority lhs, Priority rhs) {
     return lhs.getPriority() < rhs.getPriority();
   }
-  
+
 }

http://git-wip-us.apache.org/repos/asf/incubator-tez/blob/f2460aff/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskSchedulerEventHandler.java
----------------------------------------------------------------------
diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskSchedulerEventHandler.java
b/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskSchedulerEventHandler.java
index 8ee2ff9..87650f8 100644
--- a/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskSchedulerEventHandler.java
+++ b/tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskSchedulerEventHandler.java
@@ -475,7 +475,7 @@ public class TaskSchedulerEventHandler extends AbstractService
   }
 
   @Override
-  public void onError(Exception e) {
+  public void onError(Throwable t) {
     sendEvent(new DAGEvent(appContext.getDAGID(),
         DAGEventType.INTERNAL_ERROR));
   }


Mime
View raw message