Commits

Commits on Nov 18, 2021

Commits on Sep 21, 2021

[FLINK-24303][coordination] Failure when creating a source enumerator lead to full failover, not JobManager failure.
StephanEwen
committedSep 21, 2021

Commits on Sep 10, 2021

[hotfix] Improve language for error message when checkpoint is declined due to some tasks being finished already.
StephanEwen
committedSep 10, 2021

Commits on Sep 9, 2021

Commits on Sep 7, 2021

Commits on Aug 17, 2021

[FLINK-22545][tests] Fix delayed split assignment in OperatorEventSendingCheckpointITCase
StephanEwen
committedAug 17, 2021

Commits on Aug 16, 2021

Commits on Jul 21, 2021

Commits on Jul 19, 2021

[FLINK-22545][hotfix][coordination] Extend logging (temporarily) to debug test instability
StephanEwen
committedJul 19, 2021

Commits on Jul 14, 2021

[hotfix][tests] Fix deprecation warnings for OperatorCoordinatorHolderTest
StephanEwen
committedJul 14, 2021
[FLINK-22547][tests] Harden OperatorCoordinatorHolderTest.
StephanEwen
committedJul 14, 2021

Commits on Jul 13, 2021

[hotfix] Remove unnecessary warning suppression.
StephanEwen
committedJul 13, 2021
[FLINK-22545][coordination] Fix check during creation of Source Coordinator thread.
StephanEwen
committedJul 13, 2021

Commits on Jun 23, 2021

Commits on Apr 25, 2021

[hotfix][tests] Remove timout rule from KafkaTableTestBase
StephanEwen
committedApr 25, 2021
[FLINK-22433][tests] Make CoordinatorEventsExactlyOnceITCase work with Adaptive Scheduler.
StephanEwen
committedApr 25, 2021

Commits on Apr 22, 2021

[FLINK-22345][coordination] Catch pre-mature state restore for Operator Coordinators
StephanEwen
committedApr 22, 2021

Commits on Apr 21, 2021

[FLINK-22345][coordination] Remove incorrect assertion in scheduler
StephanEwen
committedApr 21, 2021

Commits on Apr 20, 2021