You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2021/12/22 02:56:40 UTC
[flink] branch master updated (1d1e72f -> e8bd52b)
This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 1d1e72f [FLINK-25399][tests] Disable changelog backend in tests
add e8bd52b [FLINK-25305][checkpoint] Always wait for input channel state and result partition state get completed in AsyncRunnable
No new revisions were added by this update.
Summary of changes:
.../runtime/tasks/AsyncCheckpointRunnable.java | 19 ++++--
.../runtime/tasks/FinishedOperatorChain.java | 13 +++-
.../streaming/runtime/tasks/OperatorChain.java | 27 ++++++++
.../runtime/tasks/RegularOperatorChain.java | 25 +------
.../tasks/StreamTaskFinalCheckpointsTest.java | 78 +++++++++++++++++++++-
.../tasks/TestFinishedOnRestoreStreamOperator.java | 12 +++-
6 files changed, 142 insertions(+), 32 deletions(-)