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 533ead6ae94 [FLINK-33198][format/avro] Properly map Avro timestamp
types in Flink Avro format
add 5c895aa670b [FLINK-33865][runtime][refactor] Refactor the
RestartStrategyType to reduce repeated magic string
add 393ef1cc439 [FLINK-33865][runtime] Adding an ITCase to ensure
`exponential-delay.attempts-before-reset-backoff` works well
No new revisions were added by this update.
Summary of changes:
.../generated/restart_strategy_configuration.html | 2 +-
.../common/restartstrategy/RestartStrategies.java | 16 +--
.../configuration/RestartStrategyOptions.java | 126 +++++++++++++++-----
.../RestartBackoffTimeStrategyFactoryLoader.java | 16 +--
...estartBackoffTimeStrategyFactoryLoaderTest.java | 36 +++---
.../runtime/jobmanager/BlobsCleanupITCase.java | 3 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 3 +-
...ecutionEnvironmentComplexConfigurationTest.java | 4 +-
...overyExponentialDelayRestartStrategyITBase.java | 4 +-
.../SimpleRecoveryFailureRateStrategyITBase.java | 4 +-
...pleRecoveryFixedDelayRestartStrategyITBase.java | 4 +-
...pdateJobResourceRequirementsRecoveryITCase.java | 3 +-
.../PipelinedRegionSchedulingITCase.java | 3 +-
.../test/scheduling/RestartStrategyITCase.java | 127 +++++++++++++++++++++
.../scheduling/SpeculativeSchedulerITCase.java | 3 +-
.../flink/yarn/YARNHighAvailabilityITCase.java | 3 +-
16 files changed, 280 insertions(+), 77 deletions(-)
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/scheduling/RestartStrategyITCase.java
