You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by je...@apache.org on 2019/02/19 17:21:58 UTC

[tez] branch master updated: TEZ-4035. Tez master breaks with YARN 3.2.0 ApplicationReport API change (jeagles)

This is an automated email from the ASF dual-hosted git repository.

jeagles pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tez.git


The following commit(s) were added to refs/heads/master by this push:
     new 4876dc2  TEZ-4035. Tez master breaks with YARN 3.2.0 ApplicationReport API change (jeagles)
4876dc2 is described below

commit 4876dc26ec2a1c365be9e5cc76a016ae715d9caa
Author: Jonathan Eagles <je...@gmail.com>
AuthorDate: Tue Feb 19 11:17:15 2019 -0600

    TEZ-4035. Tez master breaks with YARN 3.2.0 ApplicationReport API change (jeagles)
---
 .../java/org/apache/tez/mapreduce/client/NotRunningJob.java | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/NotRunningJob.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/NotRunningJob.java
index e178948..6cd9236 100644
--- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/NotRunningJob.java
+++ b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/NotRunningJob.java
@@ -84,11 +84,14 @@ public class NotRunningJob implements MRClientProtocol {
     ApplicationAttemptId unknownAttemptId = recordFactory
         .newRecordInstance(ApplicationAttemptId.class);
 
-    // Setting AppState to NEW and finalStatus to UNDEFINED as they are never
-    // used for a non running job
-    return ApplicationReport.newInstance(unknownAppId, unknownAttemptId, "N/A",
-        "N/A", "N/A", "N/A", 0, null, YarnApplicationState.NEW, "N/A", "N/A",
-        0, 0, FinalApplicationStatus.UNDEFINED, null, "N/A", 0.0f, "TEZ_MRR", null);
+    ApplicationReport report = recordFactory.newRecordInstance(ApplicationReport.class);
+    report.setUser("N/A");
+    report.setName("N/A");
+    report.setDiagnostics("N/A");
+    report.setTrackingUrl("N/A");
+    report.setStartTime(0);
+    report.setFinishTime(0);
+    return report;
   }
 
   NotRunningJob(ApplicationReport applicationReport, JobState jobState) {