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(-)
