Fail to call jobs/:jobid/cancel-with-savepoint/ with local Flink mini cluseter started by IDE

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Fail to call jobs/:jobid/cancel-with-savepoint/ with local Flink mini cluseter started by IDE

Hung
Hi Flink users,

I try to cancel a job with savepoint via REST based on https://issues.apache.org/jira/browse/FLINK-4787

I can call jobs/:jobid/cancel-with-savepoint/ in our 1.2.0 Flink cluster, but in my test environment which is done by using:

<dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-runtime-web</artifactId>
            <version>0.10.1</version>
        </dependency>

        ENVCONFIG.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true);
        ENVCONFIG.setString(ConfigConstants.JOB_MANAGER_WEB_PORT_KEY, "9991");
        ENVCONFIG.setString(ConfigConstants.JOB_MANAGER_WEB_LOG_PATH_KEY, LOG_PATH);
        StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(4, ENVCONFIG);

I got 404. Is this the problem of the version of flink-runtime-web?

Best,

Sendoh
Reply | Threaded
Open this post in threaded view
|

Re: Fail to call jobs/:jobid/cancel-with-savepoint/ with local Flink mini cluseter started by IDE

Chesnay Schepler
Hello,

The cancel-with-savepoint command is not available in 0.10.1 .
I'm pretty sure it was added in 1.2 , so you'll have to upgrade the
runtime-web dependency.

Note that all Flink dependencies should always have the same version.

Regards,
Chesnay

On 28.03.2017 18:12, Sendoh wrote:

> Hi Flink users,
>
> I try to cancel a job with savepoint via REST based on
> https://issues.apache.org/jira/browse/FLINK-4787
>
> I can call jobs/:jobid/cancel-with-savepoint/ in our 1.2.0 Flink cluster,
> but in my test environment which is done by using:
>
> <dependency>
>              <groupId>org.apache.flink</groupId>
>              <artifactId>flink-runtime-web</artifactId>
>              <version>0.10.1</version>
>          </dependency>
>
>          ENVCONFIG.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true);
>          ENVCONFIG.setString(ConfigConstants.JOB_MANAGER_WEB_PORT_KEY,
> "9991");
>          ENVCONFIG.setString(ConfigConstants.JOB_MANAGER_WEB_LOG_PATH_KEY,
> LOG_PATH);
>          StreamExecutionEnvironment env =
> StreamExecutionEnvironment.createLocalEnvironment(4, ENVCONFIG);
>
> I got 404. Is this the problem of the version of flink-runtime-web?
>
> Best,
>
> Sendoh
>
>
>
> --
> View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Fail-to-call-jobs-jobid-cancel-with-savepoint-with-local-Flink-mini-cluseter-started-by-IDE-tp12436.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
>