> *From:* Arvid Heise
> *Sent:* Saturday, February 22, 2020 1:23:01 PM
> *To:* Alexey Trenikhun
> *Cc:* user@flink.apache.org
> *Subject:* Re: async io parallelism
>
> Hi Alexey,
>
> the short answer is: order is preserved in all cases.
>
> Basically, ordered asyncI
: Re: async io parallelism
Hi Alexey,
the short answer is: order is preserved in all cases.
Basically, ordered asyncIO maintains an internal FIFO queue where all pending
elements reside. All async results are saved into this queue, but elements will
only be outputted when the head element has a
Hi Alexey,
the short answer is: order is preserved in all cases.
Basically, ordered asyncIO maintains an internal FIFO queue where all
pending elements reside. All async results are saved into this queue, but
elements will only be outputted when the head element has a result.
So assume you have
Hello,
Let's say, my elements are simple key-value pairs, elements are coming from
Kafka, where they were partitioned by "key", then I do processing using
KeyedProcessFunction (keyed by same "key"), then I enrich elements using
ordered RichAsyncFunction, then output to another KeyedProcessFuncti
