[ https://issues.apache.org/jira/browse/FLINK-11424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chesnay Schepler closed FLINK-11424. ------------------------------------ Resolution: Fixed master: f1ab95ad4a7f0c0ffd4b74878e7cb5e2db051a35 1.7: 90043718f5ac5e859d77cf984d0be7cf1a36de46 > org.apache.flink.metrics.datadog.DatadogHttpReporter#report remove will throw > exception > --------------------------------------------------------------------------------------- > > Key: FLINK-11424 > URL: https://issues.apache.org/jira/browse/FLINK-11424 > Project: Flink > Issue Type: Bug > Components: Metrics > Affects Versions: 1.6.3, 1.7.1, 1.8.0 > Reporter: lining > Assignee: lining > Priority: Major > Labels: pull-request-available > Fix For: 1.7.3, 1.8.0 > > Time Spent: 20m > Remaining Estimate: 0h > > {code:java} > for (Map.Entry<Gauge, DGauge> entry : gauges.entrySet()) { > DGauge g = entry.getValue(); > try { > // Will throw exception if the Gauge is not of Number type > // Flink uses Gauge to store many types other than Number > g.getMetricValue(); > request.addGauge(g); > } catch (Exception e) { > // Remove that Gauge if it's not of Number type > gauges.remove(entry.getKey()); > } > } > {code} > in this method remove will java.util.ConcurrentModificationException -- This message was sent by Atlassian JIRA (v7.6.3#76005)