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/05 06:16:51 UTC

[flink] branch master updated (f6d93e8 -> ae402bc)

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 f6d93e8  [FLINK-22563][docs] Add migration guide for new StateBackend interfaces
     add ae402bc  [FLINK-22379][runtime] CheckpointCoordinator checks the state of all subtasks before triggering the checkpoint

No new revisions were added by this update.

Summary of changes:
 .../file/sink/writer/FileSinkMigrationITCase.java  |  73 +++++++++++++-
 .../flink/state/api/SavepointReaderITTestBase.java |  22 ++++-
 .../state/api/SavepointReaderKeyedStateITCase.java |  22 +++--
 .../state/api/SavepointWindowReaderITCase.java     | 108 ++++++++++++---------
 .../flink/state/api/utils/OperatorLatch.java       |  52 ++++++++++
 .../flink/state/api/utils/SavepointTestBase.java   |  35 +++----
 .../flink/state/api/utils/WaitingFunction.java     |  11 +--
 .../flink/state/api/utils/WaitingSource.java       |   6 +-
 .../state/api/utils/WaitingWindowAssigner.java     |  72 ++++++++++++++
 .../DefaultCheckpointPlanCalculator.java           |   2 +-
 .../CheckpointCoordinatorTestingUtils.java         |   2 +-
 .../DefaultCheckpointPlanCalculatorTest.java       |  51 +++++++---
 12 files changed, 357 insertions(+), 99 deletions(-)
 create mode 100644 flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/utils/OperatorLatch.java
 copy flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/vector/DecimalColumnVector.java => flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/utils/WaitingFunction.java (75%)
 create mode 100644 flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/utils/WaitingWindowAssigner.java