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/18 07:16:02 UTC

[flink] branch master updated (8cf6f84 -> 7399bb4)

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

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


    from 8cf6f84  [FLINK-20695][ha] Clean ha data for job if globally terminated
     add 0528f84  [FLINK-22067][tests] Wait for vertices to using API
     add 7399bb4  [hotfix][tests] Remove try/catch from SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

No new revisions were added by this update.

Summary of changes:
 .../flink/state/api/SavepointReaderITTestBase.java |  21 +-
 .../state/api/SavepointReaderKeyedStateITCase.java |  44 +--
 .../state/api/SavepointWindowReaderITCase.java     | 368 +++++++++------------
 .../flink/state/api/utils/SavepointTestBase.java   |  45 ++-
 .../flink/state/api/utils/WaitingFunction.java     |  25 --
 .../flink/state/api/utils/WaitingSource.java       |  37 +--
 .../state/api/utils/WaitingWindowAssigner.java     |  72 ----
 7 files changed, 210 insertions(+), 402 deletions(-)
 delete mode 100644 flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/utils/WaitingFunction.java
 delete mode 100644 flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/utils/WaitingWindowAssigner.java