Commits

Commits on Aug 4, 2021

[FLINK-22891][runtime] Using CompletableFuture to sync the scheduling of checkResourceRequirements

KarmaGYZ
authored and
xintongsong
committedAug 4, 2021
[FLINK-23463][docs] Replace <div> tags with ShortCodes
KarmaGYZ
committedAug 4, 2021

Commits on Jul 20, 2021

[FLINK-23409][runtime][test] Add logs for FineGrainedSlotManager#checkResourceRequirements

KarmaGYZ
authored and
xintongsong
committedJul 20, 2021

Commits on Jul 15, 2021

[FLINK-22627][runtime] Remove unused slot request protocol

KarmaGYZ
authored and
tillrohrmann
committedJul 15, 2021
[FLINK-22627][runtime] Remove PendingSlotRequest

KarmaGYZ
authored and
tillrohrmann
committedJul 15, 2021
[FLINK-22627][runtime] Remove TaskManagerSlot

KarmaGYZ
authored and
tillrohrmann
committedJul 15, 2021
[FLINK-22627][runtime] Remove SlotManagerImpl and its related tests

KarmaGYZ
authored and
tillrohrmann
committedJul 15, 2021
[hotfix][yarn] Remove unused internal options in YarnConfigOptionsInternal

KarmaGYZ
authored and
tillrohrmann
committedJul 15, 2021

Commits on Jul 13, 2021

[FLINK-23359][test] Fix the number of available slots in testResourceCanBeAllocatedForDifferentJobAfterFree

KarmaGYZ
authored and
xintongsong
committedJul 13, 2021

Commits on Jul 5, 2021

[FLINK-21925][core] Introduce fine-grained.shuffle-mode.all-blocking to avoid resource deadlock in batch jobs that apply fine-grained resource management

KarmaGYZ
authored and
xintongsong
committedJul 5, 2021
[FLINK-21925][core] Introduce StreamExecutionEnvironment#registerSlotSharingGroup

KarmaGYZ
authored and
xintongsong
committedJul 5, 2021
[FLINK-21925][core] Introduce #slotSharingGroup(SlotSharingGroup) for configuring slot sharing group with its resource

KarmaGYZ
authored and
xintongsong
committedJul 5, 2021
[FLINK-21925][core] Introduce SlotSharingGroupUtils which contains utility for SlotSharingGroup

KarmaGYZ
authored and
xintongsong
committedJul 5, 2021
[FLINK-21925][core] Introduce public SlotSharingGroup

KarmaGYZ
authored and
xintongsong
committedJul 5, 2021
[hotfix][core] Check the cpu and heap memory to be positive when building ResourceSpec

KarmaGYZ
authored and
xintongsong
committedJul 5, 2021
[hotfix][core] Fix typo in the Builder of ResourceSpec

KarmaGYZ
authored and
xintongsong
committedJul 5, 2021

Commits on Jun 18, 2021

[FLINK-23024][rest] Make TaskManagerInfoWithSlots serializable

KarmaGYZ
authored and
tillrohrmann
committedJun 18, 2021

Commits on Jun 3, 2021

[FLINK-22683][runtime] Fix the null or incorrect value of total Flink/process memory in creating TaskExecutorMemoryConfiguration

KarmaGYZ
authored and
xintongsong
committedJun 3, 2021

Commits on May 11, 2021

[FLINK-22624][runtime] Utilize the remain resource of new pending task managers to fulfill requirement in DefaultResourceAllocationStrategy

KarmaGYZ
authored and
xintongsong
committedMay 11, 2021

Commits on May 8, 2021

[FLINK-22536][runtime] Promote the critical log in FineGrainedSlotManager to INFO level

KarmaGYZ
authored and
xintongsong
committedMay 8, 2021
[FLINK-22505][core] Limit the scale of Resource to 8

KarmaGYZ
authored and
xintongsong
committedMay 8, 2021

Commits on Apr 27, 2021

[FLINK-22074][runtime][test] Harden FineGrainedSlotManagerTest#testRequirementCheckOnlyTriggeredOnce in case deploying on a slow machine

KarmaGYZ
authored and
xintongsong
committedApr 27, 2021
[hotfix][coordination] Add log for slot allocation in FineGrainedSlotManager

KarmaGYZ
authored and
xintongsong
committedApr 27, 2021

Commits on Apr 23, 2021

[FLINK-21174][coordination] Optimize the performance of DefaultResourceAllocationStrategy

KarmaGYZ
authored and
xintongsong
committedApr 23, 2021
[hotfix] Fix typo in TestingTaskManagerResourceInfoProvider

KarmaGYZ
authored and
xintongsong
committedApr 23, 2021

Commits on Apr 20, 2021

[FLINK-22351][coordination] Promote resource declaration log to INFO in FineGrainedSlotManager

KarmaGYZ
authored and
xintongsong
committedApr 20, 2021

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