Re: Running Flink job as a rest

2020-12-03 Thread Jaffe, Julian
I can't vouch for it personally, but perhaps the Apache Bahir Netty Source for Flink could help you? It sounds like you want to use HTTPS, which this doesn't support directly, but the source might be a helpful starting point to adding the functionality you need. On 12/3/20, 1:33 AM, "Chesnay S

Re: Running Flink job as a rest

2020-12-03 Thread Chesnay Schepler
What you are asking for is an HTTP(s) source. This currently does not exist for Flink, so you would have to implement it yourself. Additionally you would have to figure out the host on which the source runs on yourself. It may be easier to setup a separate HTTP(s) server that accepts data, whi

Re: Running Flink job as a rest

2020-12-02 Thread Yun Tang
Hi Dhurandar, I'm afraid that Flink's rest API cannot satisfy your request as it would not act as any source. One possible example could be SocketWindowWordCount [1] which listens data on a port from all taskmanagers with sources. [1] https://github.com/apache/flink/blob/master/flink-examples/