flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4935) Submit job with savepoint via REST API
Date Mon, 31 Oct 2016 12:43:58 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15622050#comment-15622050

ASF GitHub Bot commented on FLINK-4935:

Github user uce commented on a diff in the pull request:

    --- Diff: docs/monitoring/rest_api.md ---
    @@ -652,3 +657,32 @@ The `savepointPath` points to the external path of the savepoint,
which can be u
       "cause": "<error message>"
    +### Submitting Programs
    +It is possible to upload, run, and list Flink programs via the REST APIs and web frontend.
    +#### Run a Program (POST)
    +Send a `POST` request to `/jars/:jarid/run`. The `jarid` parameter is the file name of
the program JAR in the configured web frontend upload directory (configuration key `jobmanager.web.upload.dir`).
    +You can specify the following query parameters (all optional):
    +- **Program arguments**: `program-args=arg1 arg2 arg3`
    +- **Main class to execute**: `entry-class=EntryClassName.class`
    +- **Default parallelism**: `parallelism=4`
    +- **Savepoint path to restore from**: `savepointPath=hdfs://path/to/savepoint`
    +- **Ignore unmapped savepoint state**:  `ignoreUnmappedState=true`
    +If the call succeeds, you will get a response with the ID of the submitted job.
    +**Example:** Run program with a savepoint
    +POST: /jars/MyProgram.jar/run?savepointPath=/my-savepoints/savepoint-1bae02a80464&ignoreUnmappedState=true
    +{"jobid": "869a9868d49c679e7355700e0857af85"}
    --- End diff --
    That's an example response.

> Submit job with savepoint via REST API
> --------------------------------------
>                 Key: FLINK-4935
>                 URL: https://issues.apache.org/jira/browse/FLINK-4935
>             Project: Flink
>          Issue Type: Improvement
>          Components: Web Client
>            Reporter: Ufuk Celebi
>            Assignee: Ufuk Celebi
> Add an option to REST API allowing to submit JARs with custom savepoint restore settings.
Currently, you cannot restore from a savepoint when using the REST API.

This message was sent by Atlassian JIRA

View raw message