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 2022/01/17 10:47:46 UTC

[flink] branch master updated (265a0a0 -> 4691b66)

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 265a0a0  [hotfix] Fix ArchivedExecutionConfigBuilder#setMaxParallelism
     add e28f4e2  [FLINK-25395][state] Don't discard changelog shared state on TM
     add 4691b66  [FLINK-25395][state] Re-upload unconfirmed RocksDB shared state

No new revisions were added by this update.

Summary of changes:
 .../changelog/ChangelogStateHandleStreamImpl.java  |  17 +-
 .../snapshot/RocksIncrementalSnapshotStrategy.java |  54 ++-----
 .../lifecycle/PartiallyFinishedSourcesITCase.java  |  12 +-
 .../operators/lifecycle/TestJobExecutor.java       |   7 +-
 .../operators/lifecycle/command/TestCommand.java   |  24 +++
 .../command/TestCommandDispatcherImpl.java         |   2 +
 .../graph/OneInputTestStreamOperator.java          |  51 +++++-
 .../graph/OneInputTestStreamOperatorFactory.java   |  11 +-
 .../operators/lifecycle/graph/TestEventSource.java |   4 +-
 .../operators/lifecycle/graph/TestJobBuilders.java |   6 +-
 .../IncrementalStateReuseAfterFailureITCase.java   | 172 +++++++++++++++++++++
 11 files changed, 293 insertions(+), 67 deletions(-)
 create mode 100644 flink-tests/src/test/java/org/apache/flink/test/checkpointing/IncrementalStateReuseAfterFailureITCase.java