[ https://issues.apache.org/jira/browse/FLINK-2720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fabian Hueske updated FLINK-2720: --------------------------------- Fix Version/s: (was: 0.10.0) 1.0.0 > Add Storm-CountMetric in flink-stormcompatibility > ------------------------------------------------- > > Key: FLINK-2720 > URL: https://issues.apache.org/jira/browse/FLINK-2720 > Project: Flink > Issue Type: New Feature > Components: Storm Compatibility > Reporter: Huang Wei > Assignee: Huang Wei > Fix For: 1.0.0 > > Original Estimate: 168h > Remaining Estimate: 168h > > Add the CountMetric for the first step of storm metrics: > 1.Do a wrapper FlinkCountMetric for CountMetric > 2.push the RuntimeContext in FlinkTopologyContext to use `addAccumulator` > method for registering the metric. -- This message was sent by Atlassian JIRA (v6.3.4#6332)