This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 580c4ae0e4e [FLINK-33975] Tests for the new Sink V2 transformations
new 8a7e5499398 [FLINK-33565][Exception] Archive exceptions into the
exception history immediately when they occur, instead of archiving them when
restarting
new bb437bd07f5 [FLINK-33565][Exception] Restart strategy checks whether
current failure is a new attempt
new 9f20bc41db8 [FLINK-33565][Scheduler] ConcurrentExceptions works with
exception merging
new d031f6008d7 [FLINK-33565][Scheduler] Correct the numberOfRestarts
metric
new ad3f13f1d5b [hotfix] Remove the wrong `@Nullable` annotation of
FailureHandlingResult due to the constructor checks `verticesToRestart` is not
null
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../failover/ExecutionFailureHandler.java | 15 +++--
...ExponentialDelayRestartBackoffTimeStrategy.java | 5 +-
.../failover/FailureHandlingResult.java | 38 +++++++++---
.../FailureRateRestartBackoffTimeStrategy.java | 3 +-
.../FixedDelayRestartBackoffTimeStrategy.java | 3 +-
.../failover/NoRestartBackoffTimeStrategy.java | 3 +-
.../failover/RestartBackoffTimeStrategy.java | 5 +-
.../flink/runtime/scheduler/DefaultScheduler.java | 10 +---
.../flink/runtime/scheduler/SchedulerBase.java | 29 +++++++--
.../FailureHandlingResultSnapshot.java | 20 ++++++-
.../RootExceptionHistoryEntry.java | 36 ++++++++----
.../failover/ExecutionFailureHandlerTest.java | 66 ++++++++++++++++++++-
...nentialDelayRestartBackoffTimeStrategyTest.java | 36 +++++++-----
.../failover/FailureHandlingResultTest.java | 28 ++++++---
.../failover/TestRestartBackoffTimeStrategy.java | 17 +++++-
.../runtime/scheduler/DefaultSchedulerTest.java | 21 +++----
.../FailureHandlingResultSnapshotTest.java | 16 +++--
.../RootExceptionHistoryEntryTest.java | 68 +++++++++++++---------
18 files changed, 302 insertions(+), 117 deletions(-)
