This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ad1c4f0 [FLINK-19843][table] Fix
ParquetFsStreamingSinkITCase.testPart which failed with 'Trying to access
closed classloader' (#13873)
add af61815 [FLINK-19703][hotfix][runtime] Remove the while-loop in
Execution#processFail
add dc50a2a [FLINK-19703][runtime] Replace the param 'isCallback' in
Execution#processFail(...) with 'cancelTask'
add ed33697 [FLINK-19703][runtime] Wrap TaskExecutionState with extra
info of internal failure handling
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/executiongraph/Execution.java | 134 ++++++++++++---------
.../runtime/executiongraph/ExecutionGraph.java | 28 ++++-
.../TaskExecutionStateTransition.java | 90 ++++++++++++++
.../flink/runtime/scheduler/DefaultScheduler.java | 12 +-
.../scheduler/InternalFailuresListener.java | 2 +-
.../flink/runtime/scheduler/SchedulerBase.java | 19 ++-
.../flink/runtime/scheduler/SchedulerNG.java | 7 +-
...pdateSchedulerNgOnInternalFailuresListener.java | 15 ++-
.../ExecutionGraphDeploymentTest.java | 5 +-
.../ExecutionPartitionLifecycleTest.java | 61 ++++------
10 files changed, 254 insertions(+), 119 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/TaskExecutionStateTransition.java
