Hi Salva, Yes, the same applies to the Operator API as the output is not thread-safe and there is no way of "checkpointing" the "in-flight" data without explicit handling. If you want to dig deeper, I would recommend to have a look also at the source code of the AsyncWaitOperator to see how you could bypass these limitations with a custom operator. In fact, you may also be able to optimise your operator for your specific usecase.
Cheers, Kostas On Wed, Feb 12, 2020 at 1:02 PM Salva Alcántara <salcantara...@gmail.com> wrote: > > Would your comment still apply if I was using AbstractStreamOperator (passing > its output when registering the callbacks) instead of a UDF? Maybe the > situation changes if I use the Operator API instead... > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
