You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/10/31 14:43:00 UTC
[jira] [Resolved] (FLINK-7936) Lack of synchronization w.r.t.
taskManagers in MetricStore#add()
[ https://issues.apache.org/jira/browse/FLINK-7936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ted Yu resolved FLINK-7936.
---------------------------
Resolution: Not A Problem
Should not be a problem after refactor.
> Lack of synchronization w.r.t. taskManagers in MetricStore#add()
> ----------------------------------------------------------------
>
> Key: FLINK-7936
> URL: https://issues.apache.org/jira/browse/FLINK-7936
> Project: Flink
> Issue Type: Bug
> Components: Metrics
> Reporter: Ted Yu
> Priority: Minor
>
> {code}
> String tmID = ((QueryScopeInfo.TaskManagerQueryScopeInfo) info).taskManagerID;
> tm = taskManagers.computeIfAbsent(tmID, k -> new TaskManagerMetricStore());
> {code}
> In other places, access to taskManagers is protected by lock on MetricStore.this
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)