Commits

Commits on Mar 24, 2021

[FLINK-21794][metrics] Support retrieving slot details via rest api

KarmaGYZ
authored and
xintongsong
committedMar 24, 2021
[hotfix][runtime] Annotate getters of TaskManagerInfo and TaskManagerDetailsInfo with JsonIgnore

KarmaGYZ
authored and
xintongsong
committedMar 24, 2021

Commits on Mar 17, 2021

[FLINK-21480][yarn][k8s] Request external resource according to TaskExecutorProcessSpec

KarmaGYZ
authored and
xintongsong
committedMar 17, 2021
[FLINK-21480][runtime] Add external resources to WorkerResourceSpec, TaskExecutorResourceSpec and TaskExecutorProcessSpec

KarmaGYZ
authored and
xintongsong
committedMar 17, 2021
[FLINK-21480][core] Introduce ExternalResource to represent all the user-defined external resource

KarmaGYZ
authored and
xintongsong
committedMar 17, 2021
[hotfix][runtime] Refactor external resource setter interface of ResourceProfile#Builder

KarmaGYZ
authored and
xintongsong
committedMar 17, 2021
[hotfix][core] Make Resource operation return the specific sub resource

KarmaGYZ
authored and
xintongsong
committedMar 17, 2021
[hotfix][runtime] Pass total resource profile instead of default slot profile to DefaultResourceAllocationStrategy

KarmaGYZ
authored and
xintongsong
committedMar 17, 2021
[hotfix][test] Remove unexpected commented-out code in AbstractFineGrainedSlotManagerITCase

KarmaGYZ
authored and
xintongsong
committedMar 17, 2021

Commits on Mar 6, 2021

[FLINK-21633][coordination] Index pending task managers in TaskManagerTracker

KarmaGYZ
authored and
xintongsong
committedMar 6, 2021

Commits on Mar 4, 2021

[FLINK-21587][test] Harden FineGrainedSlotManagerTest and AbstractFineGrainedSlotManagerITCase

KarmaGYZ
authored and
xintongsong
committedMar 4, 2021

Commits on Mar 3, 2021

[FLINK-21502][coordination] Reduce frequency of global re-allocate resources

KarmaGYZ
authored and
xintongsong
committedMar 3, 2021

Commits on Feb 28, 2021

[FLINK-21479][coordination] Provide TaskManagerResourceInfoProvider to ResourceAllocationStrategy

KarmaGYZ
authored and
xintongsong
committedFeb 28, 2021
[FLINK-21479][coordination] Introduce TaskManagerResourceInfoProvider as the read-only interface of TaskManagerTracker

KarmaGYZ
authored and
xintongsong
committedFeb 28, 2021
[hotfix][runtime] Directly pass ResourceCounter as the totalRequirements to the RequirementMatcher

KarmaGYZ
authored and
xintongsong
committedFeb 28, 2021
[hotfix][coordination] Move utility profiles to FineGrainedSlotManagerTestBase

KarmaGYZ
authored and
xintongsong
committedFeb 28, 2021

Commits on Feb 19, 2021

[FLINK-21221][runtime] Deduplication for multiple ResourceCounters

KarmaGYZ
authored and
tillrohrmann
committedFeb 19, 2021

Commits on Feb 7, 2021

[FLINK-21270][coordination] Generate the slot request respect to the resource specification of SlotSharingGroup if present

KarmaGYZ
authored and
xintongsong
committedFeb 7, 2021
[FLINK-21270][runtime] Add ResourceProfile field to ExecutionSlotSharingGroup

KarmaGYZ
authored and
xintongsong
committedFeb 7, 2021
[hotfix][runtime] Remove unused ResourceSpec field in SlotSharingGroup

KarmaGYZ
authored and
xintongsong
committedFeb 7, 2021
[hotfix][runtime] Remove unused check for the ResourceSpec of SlotSharingGroup in calculation manage memory fraction

KarmaGYZ
authored and
xintongsong
committedFeb 7, 2021
[FLINK-21047][coordination] Fix the incorrect registered/free resources information exposed by SlotManager

KarmaGYZ
authored and
xintongsong
committedFeb 7, 2021
[FLINK-21273][coordination] Remove unused ExecutionVertexSchedulingRequirements

KarmaGYZ
authored and
zhuzhurk
committedFeb 7, 2021

Commits on Feb 5, 2021

[FLINK-21269][runtime] Introduce runtime interfaces for specifying SlotSharingGroup-based resource requirements

KarmaGYZ
authored and
xintongsong
committedFeb 5, 2021
[FLINK-21269][runtime] Add ResourceProfile field to SlotSharingGroup

KarmaGYZ
authored and
xintongsong
committedFeb 5, 2021

Commits on Feb 4, 2021

[FLINK-20835][test] Setup Azure build for running core and flink-tests for fine-grained resource management

KarmaGYZ
authored and
xintongsong
committedFeb 4, 2021
[FLINK-20835][coordination] Introduce FineGrainedSlotManager

KarmaGYZ
authored and
xintongsong
committedFeb 4, 2021
[FLINK-20835][coordination] Introduce ResourceAllocationStrategy and its default implementation for fine-grained resource management

KarmaGYZ
authored and
xintongsong
committedFeb 4, 2021
[FLINK-20835][coordination] Introduce the SlotStatusSyncer to allocate/free slot and reconcile the slot status

KarmaGYZ
authored and
xintongsong
committedFeb 4, 2021
[FLINK-20835][coordination] Introduce TaskManagerTracker to track TaskManager's resource and slot status

KarmaGYZ
authored and
xintongsong
committedFeb 4, 2021
[FLINK-20835][coordination] Introduce WorkerResourceSpec#fromTotalResourceProfile for generating the require resources from pending task managers

KarmaGYZ
authored and
xintongsong
committedFeb 4, 2021
[FLINK-20835][coordination] Add fine-grained resource management feature toggle

KarmaGYZ
authored and
xintongsong
committedFeb 4, 2021
[hotfix][coordination] Add getters of AllocationID, JobID and SlotState in TaskManagerSlotInformation

KarmaGYZ
authored and
xintongsong
committedFeb 4, 2021
[hotfix][coordination] Move utility methods of SlotManager to SlotManagerUtils for deduplication

KarmaGYZ
authored and
xintongsong
committedFeb 4, 2021
[hotfix][coordination] Adjust TaskExecutor resource to reasonably large value for local execution

KarmaGYZ
authored and
xintongsong
committedFeb 4, 2021