[ 
https://issues.apache.org/jira/browse/FLINK-10081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Till Rohrmann closed FLINK-10081.
---------------------------------
    Resolution: Later

Maybe we will address this problem later. At the moment it is not a big problem.

> Asynchronous (un)registration of metrics
> ----------------------------------------
>
>                 Key: FLINK-10081
>                 URL: https://issues.apache.org/jira/browse/FLINK-10081
>             Project: Flink
>          Issue Type: Improvement
>          Components: Runtime / Metrics
>            Reporter: Chesnay Schepler
>            Priority: Major
>
> Currently, whenever a metric is (un)registered the calling thread iterates 
> over all reporters and executes their registration logic, which may involve 
> slow or even blocking operations depending on the reporter implementation. 
> For scheduled reporters this also introduces concurrency as registration can 
> occur while a report is being created, potentially causing exceptions as seen 
> in FLINK-10035.
> I propose to make the registration of metrics asynchronous, i.e. when a 
> metric is registered it is simply put in a queue instead that the metrics 
> thread (that is also doing the reporting) would pull from.
> This further isolates jobmanager/taskmanager/task threads from user-code, 
> should speed up deployment/shutdown of tasks and makes interactions with 
> reporters single-threaded.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to