Versions Compared

Old Version 23

changes.mady.by.user Yi Zhang

Saved on

compared with

New Version Current

changes.mady.by.user Yi Zhang

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

We plan to modify the /jars/:jarid/run REST API by adding an applicationId field to both the request and response bodies. The values of jobId and applicationId in different cases are as follows:in the response body, allowing users to manage the corresponding application afterward. Currently, the API runs the user’s main method and returns a single job ID. To ensure full backward compatibility, this behavior will remain unchanged, and the newly added applicationId will simply mirror the job ID in the response.

Specified jobId

Specified applicationId

Actual jobId

Actual applicationId

✅

✅

specified jobId

specified applicationId

✅

❌

specified jobId

same as jobId

❌

✅

same as applicationId

specified applicationId

❌

❌

same as applicationId

randomly generated

/jars/:jarid/run
Verb: POSTResponse code: 200 OK
Submits an application by running a jar previously uploaded via '/jars/upload'.

Request

{
  "type" : "object",
  "id" : "urn:jsonschema:org:apache:flink:runtime:webmonitor:handlers:JarRunRequestBody",
    "entryClass" : {
      "type" : "string"
    },
    "flinkConfiguration" : {
      "type" : "object",
      "additionalProperties" : {
        "type" : "string"
      }
    },
    "jobId" : {
      "type" : "any"
    },
    " applicationId" : {
      "type" : "any"
    },
    "parallelism" : {
      "type" : "integer"
    },
    "programArgsList" : {
      "type" : "array",
      "items" : {
        "type" : "string"
      }
    },
    "allowNonRestoredState" : {
      "type" : "boolean"
    },
    "claimMode" : {
      "type" : "string",
      "enum" : [ "CLAIM", "NO_CLAIM", "LEGACY" ]
    },
    "savepointPath" : {
      "type" : "string"
    }
  }
}

Response

{
  "type" : "object",
  "id" : "urn:jsonschema:org:apache:flink:runtime:webmonitor:handlers:JarRunResponseBody",
  "properties" : {
    "jobIdjobid" : {
      "type" : "any"
    },
    "applicationId" : {
      "type" : "any"
    }
  }
}

...