Commits

Commits on Apr 16, 2021

[FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime
tillrohrmann
committedApr 16, 2021

Commits on Apr 15, 2021

[hotfix] Let JobMasterStopWithSavepointITCase.ExceptionOnCallbackStreamTask implement finishTask to finish
tillrohrmann
committedApr 15, 2021

Commits on Apr 13, 2021

[hotfix] Correct log statement content
tillrohrmann
committedApr 13, 2021

Commits on Apr 9, 2021

[hotfix] Use AllocationID instead of JobID when slot cannot be marked as active.
tillrohrmann
committedApr 9, 2021

Commits on Apr 8, 2021

Commits on Apr 7, 2021

[FLINK-22014][ha] Make sure that AbstractHaServices delete first the HA data before deleting blobs on closeAndCleanupAllData
tillrohrmann
committedApr 7, 2021

Commits on Apr 6, 2021

[FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime
tillrohrmann
committedApr 6, 2021

Commits on Apr 1, 2021

Commits on Mar 31, 2021

Commits on Mar 26, 2021

Commits on Mar 23, 2021

Commits on Mar 20, 2021

[FLINK-21602] Track asynchronous background tasks in the AdaptiveScheduler
tillrohrmann
committedMar 20, 2021
[hotfix] Add FutureUtils.switchExecutor utility
tillrohrmann
committedMar 20, 2021
[FLINK-21602] Allow SchedulerNG to terminate asynchronously
tillrohrmann
committedMar 20, 2021
[hotfix] Rename SchedulerNG.getTerminationFuture into getJobTerminationFuture
tillrohrmann
committedMar 20, 2021
[hotfix] Annotate CheckpointsCleaner with @threadsafe
tillrohrmann
committedMar 20, 2021
[hotfix] Factor ExecutionGraph creation out into ExecutionGraphFactory
tillrohrmann
committedMar 20, 2021
[FLINK-21602] Split ExecutionGraph generation and slot assignments into two steps
tillrohrmann
committedMar 20, 2021
[hotfix] Make SlotAllocator configurable for the AdaptiveScheduler
tillrohrmann
committedMar 20, 2021
[hotfix] Make TestExecutorResource generic in the ExecutorService
tillrohrmann
committedMar 20, 2021
[FLINK-21602] Let SlotSharingSlotAllocator check whether resources are available before reserving them
tillrohrmann
committedMar 20, 2021
[FLINK-21602] Add DeclarativeSlotPool. and AllocatedSlotPool.containsFreeSlot
tillrohrmann
committedMar 20, 2021
[FLINK-21602] Make SlotAllocator.tryReserveSlots failable
tillrohrmann
committedMar 20, 2021
[FLINK-21602] Remove generic parameter from SlotAllocator
tillrohrmann
committedMar 20, 2021
[hotfix] Let Restarting and WaitingForResources cancel scheduled tasks onLeave
tillrohrmann
committedMar 20, 2021