Flink-1.11.1 Rest API使用

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

Flink-1.11.1 Rest API使用

amenhub@163.com
hi everyone,

如[1]所示的Rest API该怎么进行参数设置并在postman中测试呢?疑惑的地方在于其中的Query Parameter参数例如mode该怎么传给URL?如果有例子说明,感激不尽

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/monitoring/rest_api.html#jobs-jobid-1

best,
amenhub
Reply | Threaded
Open this post in threaded view
|

Re: Flink-1.11.1 Rest API使用

Husky Zeng
jobId=123456  mode选择cancel

那么你发送
<a href="http://ip:port/../jobs/123456?mode=cancel">http://ip:port/../jobs/123456?mode=cancel





--
Sent from: http://apache-flink.147419.n8.nabble.com/
Reply | Threaded
Open this post in threaded view
|

Re: Re: Flink-1.11.1 Rest API使用

amenhub@163.com
感谢回复,

不过好像没有用,是因为我使用per-job方式提交到yarn,然后yarn代理的URL无法响应吗?

我测试其他很多接口还都会报405异常‘HTTP method POST is not supported by this URL’...

best,
amenhub



 
发件人: Husky Zeng
发送时间: 2020-10-22 11:17
收件人: user-zh
主题: Re: Flink-1.11.1 Rest API使用
jobId=123456  mode选择cancel
 
那么你发送
<a href="http://ip:port/../jobs/123456?mode=cancel">http://ip:port/../jobs/123456?mode=cancel
 
 
 
 
 
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Reply | Threaded
Open this post in threaded view
|

Re: Re: Flink-1.11.1 Rest API使用

caozhen
是使用的PATCH请求嘛?


--------


[hidden email] wrote

> 感谢回复,
>
> 不过好像没有用,是因为我使用per-job方式提交到yarn,然后yarn代理的URL无法响应吗?
>
> 我测试其他很多接口还都会报405异常‘HTTP method POST is not supported by this URL’...
>
> best,
> amenhub
>
>
>
>  
> 发件人: Husky Zeng
> 发送时间: 2020-10-22 11:17
> 收件人: user-zh
> 主题: Re: Flink-1.11.1 Rest API使用
> jobId=123456  mode选择cancel
>  
> 那么你发送
> <a href="http://ip:port/../jobs/123456?mode=cancel">http://ip:port/../jobs/123456?mode=cancel
>  
>  
>  
>  
>  
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/





--
Sent from: http://apache-flink.147419.n8.nabble.com/
Reply | Threaded
Open this post in threaded view
|

Re: Re: Flink-1.11.1 Rest API使用

Husky Zeng
In reply to this post by amenhub@163.com
其他接口大多不是post类型,你要修改成get或者其他的。可以先仔细阅读一下你发的这个页面上面的介绍,看看部署有没有出错。



--
Sent from: http://apache-flink.147419.n8.nabble.com/
Reply | Threaded
Open this post in threaded view
|

Re: Flink-1.11.1 Rest API使用

Peidian Li
Yarn 的proxy server不支持POST请求,这是前几天yarn同事给我截的图:
我们改了下proxy server的逻辑来支持POST请求就可以了


一个stop with savepoint例子:

Request body:
{
"drain" : true,
"targetDirectory" : "<a href="hdfs://zjyprc-hadoop/user/s_flink_tst/checkpoints4" class="">hdfs://zjyprc-hadoop/user/s_flink_tst/checkpoints4"
}

Response:
{
"request-id": "69416efc4538f56759f77a3001c38ff8"
}

2020年10月22日 下午2:30,Husky Zeng <[hidden email]> 写道:

其他接口大多不是post类型,你要修改成get或者其他的。可以先仔细阅读一下你发的这个页面上面的介绍,看看部署有没有出错。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Reply | Threaded
Open this post in threaded view
|

Re: Re: Flink-1.11.1 Rest API使用

amenhub@163.com
还真是不支持,多谢解惑~


 
发件人: [hidden email]
发送时间: 2020-10-22 19:13
收件人: [hidden email]
主题: Re: Flink-1.11.1 Rest API使用
Yarn 的proxy server不支持POST请求,这是前几天yarn同事给我截的图:
我们改了下proxy server的逻辑来支持POST请求就可以了


一个stop with savepoint例子:

Request body:
{
"drain" : true,
"targetDirectory" : "<a href="hdfs://zjyprc-hadoop/user/s_flink_tst/checkpoints4" class="">hdfs://zjyprc-hadoop/user/s_flink_tst/checkpoints4"
}

Response:
{
"request-id": "69416efc4538f56759f77a3001c38ff8"
}

2020年10月22日 下午2:30,Husky Zeng <[hidden email]> 写道:

其他接口大多不是post类型,你要修改成get或者其他的。可以先仔细阅读一下你发的这个页面上面的介绍,看看部署有没有出错。



--
Sent from: http://apache-flink.147419.n8.nabble.com/