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

Posted to commits@flink.apache.org by lz...@apache.org on 2021/11/10 07:18:08 UTC

[flink] branch master updated (4dd04bd -> cba6b2c)

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

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 4dd04bd  [FLINK-24658][runtime] Added debug logs for BufferDebloater
     add cba6b2c  [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregate operator

No new revisions were added by this update.

Summary of changes:
 .../processors/AbstractWindowAggProcessor.java     |  7 ++++
 .../RowTimeWindowDeduplicateProcessor.java         |  5 +++
 .../window/processors/WindowRankProcessor.java     |  7 +++-
 .../window/slicing/SlicingWindowOperator.java      | 45 +++++++++++++++++++++-
 .../window/slicing/SlicingWindowProcessor.java     |  8 ++++
 .../window/SlicingWindowAggOperatorTest.java       | 21 ++++++----
 6 files changed, 83 insertions(+), 10 deletions(-)