[Rest API] Add task state; Add job's retry details; Refine job config

docs/rest-server/API.md

@@ -440,10 +440,16 @@ Status: 200
     createdTime: "createdTimestamp",
     completedTime: "completedTimestamp",
     executionType: "executionType",
-    // Sum of succeededRetriedCount, transientNormalRetriedCount,
-    // transientConflictRetriedCount, nonTransientRetriedCount,
-    // and unKnownRetriedCount
-    retries: retriedCount,
+    // sum of retries
+    retries: retries,
+    retryDetails: {
+      // Job failed due to user or unknown error
+      user: userRetries,
+      // Job failed due to platform error
+      platform: platformRetries,
+      // Job cannot get required resource to run within timeout
+      resource: resourceRetries,
+    },
     appId: "applicationId",
     appProgress: "applicationProgress",
     appTrackingUrl: "applicationTrackingUrl",
@@ -461,6 +467,7 @@ Status: 200
       },
       taskStatuses: {
         taskIndex: taskIndex,
+        taskState: taskState,
         containerId: "containerId",
         containerIp: "containerIp",
         containerPorts: {

src/rest-server/src/controllers/job.js

@@ -16,6 +16,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
 // module dependencies
+const yaml = require('js-yaml');
 const Job = require('../models/job');
 const createError = require('../util/error');
 const logger = require('../config/logger');
@@ -149,8 +150,10 @@ const getConfig = (req, res, next) => {
     req.job.name,
     (error, result) => {
       if (!error) {
-        // result maybe json or yaml, depends on the job type user submitted.
-        return typeof(result) == 'string' ? res.status(200).json(result) : res.status(200).send(result).type('yaml');
+        const data = yaml.safeLoad(result);
+        const type = req.accepts(['json', 'yaml']) || 'json';
+        const body = type === 'json' ? JSON.stringify(data) : yaml.safeDump(data);
+        return res.status(200).type(type).send(body);
       } else if (error.message.startsWith('[WebHDFS] 404')) {
         return next(createError('Not Found', 'NoJobConfigError', `Config of job ${req.job.name} is not found.`));
       } else {

src/rest-server/src/models/job.js

@@ -59,9 +59,9 @@ class Job {
         jobState = 'RUNNING';
         break;
       case 'FRAMEWORK_COMPLETED':
-        if (typeof exitCode !== 'undefined' && parseInt(exitCode) === 0) {
+        if (exitCode === 0) {
           jobState = 'SUCCEEDED';
-        } else if (typeof exitCode !== 'undefined' && parseInt(exitCode) == 214) {
+        } else if (exitCode === 214) {
           jobState = 'STOPPED';
         } else {
           jobState = 'FAILED';
@@ -73,6 +73,26 @@ class Job {
     return jobState;
   }
 
+  convertTaskState(taskState, exitCode) {
+    switch (taskState) {
+      case 'TASK_WAITING':
+      case 'CONTAINER_REQUESTED':
+      case 'CONTAINER_ALLOCATED':
+      case 'CONTAINER_COMPLETED':
+        return 'WAITING';
+      case 'CONTAINER_RUNNING':
+        return 'RUNNING';
+      case 'TASK_COMPLETED':
+        if (exitCode === 0) {
+          return 'SUCCEEDED';
+        } else {
+          return 'FAILED';
+        }
+      default:
+        return 'UNKNOWN';
+    }
+  }
+
   getJobList(query, namespace, next) {
     let reqPath = launcherConfig.frameworksPath();
     if (namespace) {
@@ -90,18 +110,30 @@ class Job {
             return next(null, createError(res.status, 'UnknownError', res.raw_body));
           }
           let jobList = resJson.summarizedFrameworkInfos.map((frameworkInfo) => {
-            let retries = 0;
-            ['succeededRetriedCount', 'transientNormalRetriedCount', 'transientConflictRetriedCount',
-              'nonTransientRetriedCount', 'unKnownRetriedCount'].forEach((retry) => {
-                retries += frameworkInfo.frameworkRetryPolicyState[retry];
-              });
+            // 1. transientNormalRetriedCount
+            //    Failed, and it can ensure that it will success within a finite retry times:
+            //    such as dependent components shutdown, machine error, network error,
+            //    configuration error, environment error...
+            // 2. transientConflictRetriedCount
+            //    A special TRANSIENT_NORMAL which indicate the exit due to resource conflict
+            //    and cannot get required resource to run.
+            // 3. unKnownRetriedCount
+            //    Usually caused by user's code.
+            const platformRetries = frameworkInfo.frameworkRetryPolicyState.transientNormalRetriedCount;
+            const resourceRetries = frameworkInfo.frameworkRetryPolicyState.transientConflictRetriedCount;
+            const userRetries = frameworkInfo.frameworkRetryPolicyState.unKnownRetriedCount;
             const job = {
               name: frameworkInfo.frameworkName,
               username: frameworkInfo.userName,
               state: this.convertJobState(frameworkInfo.frameworkState, frameworkInfo.applicationExitCode),
               subState: frameworkInfo.frameworkState,
               executionType: frameworkInfo.executionType,
-              retries: retries,
+              retries: platformRetries + resourceRetries + userRetries,
+              retryDetails: {
+                user: userRetries,
+                platform: platformRetries,
+                resource: resourceRetries,
+              },
               createdTime: frameworkInfo.firstRequestTimestamp || new Date(2018, 1, 1).getTime(),
               completedTime: frameworkInfo.frameworkCompletedTimestamp,
               appExitCode: frameworkInfo.applicationExitCode,
@@ -252,7 +284,7 @@ class Job {
             null,
             (error, result) => {
               if (!error) {
-                next(null, JSON.stringify(JSON.parse(result.content), null, 2));
+                next(null, result.content);
               } else {
                 next(error);
               }
@@ -333,22 +365,24 @@ class Job {
     if (frameworkStatus) {
       const jobState = this.convertJobState(
         frameworkStatus.frameworkState,
-        frameworkStatus.applicationExitCode);
-      let jobRetryCount = 0;
-      const jobRetryCountInfo = frameworkStatus.frameworkRetryPolicyState;
-      jobRetryCount =
-        jobRetryCountInfo.succeededRetriedCount +
-        jobRetryCountInfo.transientNormalRetriedCount +
-        jobRetryCountInfo.transientConflictRetriedCount +
-        jobRetryCountInfo.nonTransientRetriedCount +
-        jobRetryCountInfo.unKnownRetriedCount;
+        frameworkStatus.applicationExitCode,
+      );
+
+      const platformRetries = frameworkStatus.frameworkRetryPolicyState.transientNormalRetriedCount;
+      const resourceRetries = frameworkStatus.frameworkRetryPolicyState.transientConflictRetriedCount;
+      const userRetries = frameworkStatus.frameworkRetryPolicyState.unKnownRetriedCount;
       jobDetail.jobStatus = {
         name: framework.name,
         username: 'unknown',
         state: jobState,
         subState: frameworkStatus.frameworkState,
         executionType: framework.summarizedFrameworkInfo.executionType,
-        retries: jobRetryCount,
+        retries: platformRetries + resourceRetries + userRetries,
+        retryDetails: {
+          user: userRetries,
+          platform: platformRetries,
+          resource: resourceRetries,
+        },
         createdTime: frameworkStatus.frameworkCreatedTimestamp,
         completedTime: frameworkStatus.frameworkCompletedTimestamp,
         appId: frameworkStatus.applicationId,
@@ -388,6 +422,7 @@ class Job {
           }
           jobDetail.taskRoles[taskRole].taskStatuses.push({
             taskIndex: task.taskIndex,
+            taskState: this.convertTaskState(task.taskState, task.containerExitCode),
             containerId: task.containerId,
             containerIp: task.containerIp,
             containerPorts,