Commits

Branch selector

 master

User selector

1996fanrui

Datepicker

All time

Commit History

Commits on Feb 20, 2024

• [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes

  1996fanrui

  committed
  e2e3de2

Commits on Feb 8, 2024

• [FLINK-34200][test] Fix the bug that AutoRescalingITCase.testCheckpointRescalingInKeyedState fails occasionally

  1996fanrui

  committed
  1b95b19

• [hotfix][tests] Disables cool down phase for faster test execution

  1996fanrui

  committed
  9d7de68

• [FLINK-33960][Scheduler] Fix the bug that Adaptive Scheduler doesn't respect the lowerBound when one flink job has more than 1 tasks

  1996fanrui

  committed
  777e96f

• [FLINK-33960][JUnit5 migration] Migrate SlotSharingSlotAllocatorTest to Junit5 and Assertj

  1996fanrui

  committed
  71336d6

Commits on Feb 6, 2024

• [FLINK-33739][doc] Document FLIP-364: Improve the exponential-delay restart-strategy

  1996fanrui

  committed
  2f040e3

Commits on Feb 5, 2024

• [FLINK-34247][doc] Fix the wrong zh link for flink-configuration-file and repeated flink configuration file

  1996fanrui

  committed
  d44e940

Commits on Jan 24, 2024

• [FLINK-33865][runtime] Adding an ITCase to ensure exponential-delay.attempts-before-reset-backoff works well

  1996fanrui

  committed
  393ef1c

• [FLINK-33865][runtime][refactor] Refactor the RestartStrategyType to reduce repeated magic string

  1996fanrui

  committed
  5c895aa

Commits on Jan 23, 2024

• [hotfix] Remove the wrong @Nullable annotation of FailureHandlingResult due to the constructor checks verticesToRestart is not null

  1996fanrui

  committed
  ad3f13f

• [FLINK-33565][Scheduler] Correct the numberOfRestarts metric

  1996fanrui

  committed
  d031f60

• [FLINK-33565][Scheduler] ConcurrentExceptions works with exception merging

  1996fanrui

  committed
  9f20bc4

• [FLINK-33565][Exception] Restart strategy checks whether current failure is a new attempt

  1996fanrui

  committed
  bb437bd

• [FLINK-33565][Exception] Archive exceptions into the exception history immediately when they occur, instead of archiving them when restarting

  1996fanrui

  committed
  8a7e549

Commits on Jan 22, 2024

• [FLINK-34081][configuration] Refactor all callers of deprecated getXxx(ConfigOption<Xxx>), getXxx(ConfigOption<Xxx>, Xxx) and setXxx(ConfigOption<Integer>, Xxx) methods of Configuration

  1996fanrui

  committed
  c8f27c2

Commits on Jan 19, 2024

• [FLINK-34080][configuration] Remove the @Deprecated for getString(String key, String defaultValue) of Configuration

  1996fanrui

  committed
  725b3ed

• [FLINK-34080][configuration] Deprecate all getXxx and setXxx methods for Configuration

  1996fanrui

  committed
  a2cc47a

• [FLINK-34080][configuration] Add the T get(ConfigOption<T> configOption, T overrideDefault) for Configuration

  1996fanrui

  committed
  79abfaa

Commits on Jan 11, 2024

• [FLINK-32852][hotfix] DefaultSchedulerTest should use the LOG instead of TestLogger of junit4

  1996fanrui

  committed
  8a04ae0

• [FLINK-32852][JUnit5 migration] Migrate ExceptionHistoryEntryTest and RootExceptionHistoryEntryTest to Junit5 and Assertj

  1996fanrui

  committed
  a6412b8

Commits on Jan 10, 2024

• [FLINK-33738][Scheduler] Document the default restart strategy for exponential-delay

  1996fanrui

  committed
  cad090a

• [FLINK-33738][Scheduler] Make exponential-delay restart-strategy the default restart strategy

  1996fanrui

  committed
  d9fc5ee

Commits on Jan 8, 2024

• [FLINK-33737][Scheduler] Merge multiple Exceptions into one attempt for exponential-delay restart-strategy

  1996fanrui

  committed
  ef3cefd

• [FLINK-33737][Scheduler][refactor] Replace currentBackoffMS and lastFailureTimestamp with nextRestartTimestamp

  1996fanrui

  committed
  f9738d6

Commits on Jan 5, 2024

• [FLINK-33935][checkpoint] Improve the default value logic related to state.backend.type

  1996fanrui

  committed
  4a852fe

• [FLINK-33935][checkpoint] Improve the default value logic related to execution.checkpointing.tolerable-failed-checkpoints

  1996fanrui

  committed
  cf0ac00

Commits on Dec 29, 2023

• [FLINK-33942][configuration][refactor] Using ConfigOption instead of string key in DelegatingConfiguration

  1996fanrui

  committed
  c6865d9

• [FLINK-33942][configuration] Fix the bug that DelegatingConfiguration misses the prefix in some get methods

  1996fanrui

  committed
  969a5c6

• [FLINK-33942][configuration][junit5-migration] Migrate DelegatingConfigurationTest to Junit5 and Assertj

  1996fanrui

  committed
  f66b943

Commits on Dec 26, 2023

• [FLINK-33736][Scheduler] Update default value of exponential-delay.max-backoff and exponential-delay.backoff-multiplier

  1996fanrui

  committed
  d9e8b2a

Commits on Dec 15, 2023

• [FLINK-32895][Scheduler][refactor] Remove some unused throws

  1996fanrui

  committed
  3d4d396

• [FLINK-32895][Scheduler] Introduce the max attempts for Exponential Delay Restart Strategy

  1996fanrui

  committed
  80e71a4

• [FLINK-32895][Scheduler][refactor] Generate the latest strategy string for ExponentialDelayRestartBackoffTimeStrategy due to some information will be updated

  1996fanrui

  committed
  1c7b108

Commits on Dec 7, 2023

• [FLINK-33693][checkpoint] Force aligned barrier works with timeoutable aligned checkpoint barrier

  1996fanrui

  committed
  a4d14ec

Commits on Dec 6, 2023

• [FLINK-33752][Configuration] Change the displayed timeunit to day when the duration is an integral multiple of 1 day

  1996fanrui

  committed
  360abe6

Pagination

PreviousNext