t; --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Flink-requesting-external-web-
> service-with-rate-limited-requests-tp11952p11977.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
0.n4.nabble.com/Flink-requesting-external-web-service-with-rate-limited-requests-tp11952p11977.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
A SourceFunction may only emit records when it holds the checkpointLock
(just as `ContinuousFileMonitoringFunction` does).
Flink only emits a checkpoint if it holds the lock. This ensures correct
behavior.
Best, Fabian
2017-02-28 10:58 GMT+01:00 Yassine MARZOUGUI :
> Hi Fabian,
>
> I have a rel
great.
>>
>> So my question is if there is a nice way to limit the flow of messages on
>> the system according to the rate given by a sink function? Is there any
>> other way I could make this work on Flink?
>>
>> Thank you
>>
>>
>>
>> --
>> View this message in context: http://apache-flink-user-maili
>> ng-list-archive.2336050.n4.nabble.com/Flink-requesting-
>> external-web-service-with-rate-limited-requests-tp11952.html
>> Sent from the Apache Flink User Mailing List archive. mailing list
>> archive at Nabble.com.
>>
>
>
e this work on Flink?
>
> Thank you
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Flink-requesting-external-web-
> service-with-rate-limited-requests-tp11952.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
rding to the rate given by a sink function? Is there any
other way I could make this work on Flink?
Thank you
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-requesting-external-web-service-with-rate-limited-requests-tp11952.html
Se
