Zakelly Lan created FLINK-34704: ----------------------------------- Summary: Process checkpoint barrier in AsyncWaitOperator when the element queue is full Key: FLINK-34704 URL: https://issues.apache.org/jira/browse/FLINK-34704 Project: Flink Issue Type: Improvement Components: Runtime / Task Reporter: Zakelly Lan
As discussed in https://lists.apache.org/thread/4f7ywn29kdv4302j2rq3fkxc6pc8myr2 . Maybe it is better to provide such a new `yield` that can process mail with low priority in the mailbox executor. More discussion needed. -- This message was sent by Atlassian Jira (v8.20.10#820010)