You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Xintong Song (Jira)" <ji...@apache.org> on 2020/03/10 02:24:00 UTC
[jira] [Updated] (FLINK-16440) Extend SlotManager metrics and
status for dynamic slot allocation.
[ https://issues.apache.org/jira/browse/FLINK-16440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Xintong Song updated FLINK-16440:
---------------------------------
Description:
* Create a slotManagerMetricGroup in resourceManagerMetricGroup, pass it into SM and register slot related metrics there.
** This allows registering different metrics for different SM implementation.
** For backwards compatibility, the slotManagerMetricGroup should have the same path as the resourceManagerMetricGroup.
* Extend ResourceOverview and TaskManagerInfo to contain TM total / free / allocated resources.
** Need to add methods to SM for getting TM resource status.
** For SlotManagerImpl,
*** The existing methods for getting number of registered / free slots need no changes.
*** TM resource status can be computed from TaskExecutorProcessSpec, slot profiles and number of free slots.
was:
* Create a slotManagerMetricGroup in resourceManagerMetricGroup, pass it into SM and register slot related metrics there.
* This allows registering different metrics for different SM implementation.
* For backwards compatibility, the slotManagerMetricGroup should have the same path as the resourceManagerMetricGroup.
* Extend ResourceOverview and TaskManagerInfo to contain TM total / free / allocated resources.
* Need to add methods to SM for getting TM resource status.
* For SlotManagerImpl,
* The existing methods for getting number of registered / free slots need no changes.
* TM resource status can be computed from TaskExecutorProcessSpec, slot profiles and number of free slots.
> Extend SlotManager metrics and status for dynamic slot allocation.
> ------------------------------------------------------------------
>
> Key: FLINK-16440
> URL: https://issues.apache.org/jira/browse/FLINK-16440
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Metrics
> Reporter: Xintong Song
> Priority: Major
> Fix For: 1.11.0
>
>
> * Create a slotManagerMetricGroup in resourceManagerMetricGroup, pass it into SM and register slot related metrics there.
> ** This allows registering different metrics for different SM implementation.
> ** For backwards compatibility, the slotManagerMetricGroup should have the same path as the resourceManagerMetricGroup.
> * Extend ResourceOverview and TaskManagerInfo to contain TM total / free / allocated resources.
> ** Need to add methods to SM for getting TM resource status.
> ** For SlotManagerImpl,
> *** The existing methods for getting number of registered / free slots need no changes.
> *** TM resource status can be computed from TaskExecutorProcessSpec, slot profiles and number of free slots.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)