You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ro...@apache.org on 2021/05/03 12:55:16 UTC

[flink] branch release-1.12 updated (cc9e8dd -> afc0a90)

This is an automated email from the ASF dual-hosted git repository.

roman pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from cc9e8dd  Update japicmp configuration and docs for 1.12.3
     add afc0a90  [FLINK-22368] Deque channel after releasing on EndOfPartition

No new revisions were added by this update.

Summary of changes:
 .../io/network/partition/PrioritizedDeque.java     | 23 +++++++++++++++
 .../partition/consumer/SingleInputGate.java        | 33 +++++++++++++---------
 2 files changed, 43 insertions(+), 13 deletions(-)