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) {