Posting this to dev as well...
Thanks Zakelly,
Sounds like a solution could be to add a new different version of yield
that would actually yield to the checkpoint barrier too. That way operator
implementations could decide whether any state modification may or may not
have happened and can optiona
I agree. Also create https://issues.apache.org/jira/browse/FLINK-34704 for
tracking and further discussion.
Best,
Zakelly
On Fri, Mar 15, 2024 at 2:59 PM Gyula Fóra wrote:
> Posting this to dev as well...
>
> Thanks Zakelly,
> Sounds like a solution could be to add a new different version of y