你好，我想到一个异步方案，不知道是否能满足需求，可供参考：
1、接收端，我同意Caizhi Weng的说法，还是要另起一个http server服务a：把请求的参数放入消息队列中，同时服务a通知调用方请求已收到。
2、flink从消息队列中消费数据，并将参数进行解析，业务逻辑处理。
3、sink端可以考虑继承RichSinkFunction类，将解析结果再通过调用对方的http服务传回去，在invoke方法中post数据即可。
sink端可以参考这个代码
public class HttpResultSink extends RichSinkFunction {
private Cl
我觉得这种方式是可行的，请问一下我应该如何去做，有没有一些资料参考一下呢
Caizhi Weng 于2022年2月9日周三 16:15写道：
> Hi！
>
> Flink 目前没有 http server source / sink。这是一个 OLAP
> 的需求吗？从描述的需求来看，一种更加合理的方式应该是有一个专门的 http server 接受请求，调用 Flink API 运行一个 Flink
> 作业（Flink SQL 可以运行 select 语句），再将结果返回给调用方。
>
> 张锴 于2022年2月9日周三 14:28写道：
>
> >
> >
> 业务需求：通过
Hi！
Flink 目前没有 http server source / sink。这是一个 OLAP
的需求吗？从描述的需求来看，一种更加合理的方式应该是有一个专门的 http server 接受请求，调用 Flink API 运行一个 Flink
作业（Flink SQL 可以运行 select 语句），再将结果返回给调用方。
张锴 于2022年2月9日周三 14:28写道：
>
> 业务需求：通过http请求方式将参数传给flink,将参数带入flink程序再把结果以json的形式返回。请问一下以这种方式实时计算，flink是否支持？
>
> flink版本:1.12.1
>
业务需求：通过http请求方式将参数传给flink,将参数带入flink程序再把结果以json的形式返回。请问一下以这种方式实时计算，flink是否支持？
flink版本:1.12.1
