@Matthias
Thanks for the advice.
I opened a JIRA and a PR for the first step about the storm metrics.
If you think this is OK, I'll do a integrated test and add all the storm
metrics in future.
Greetings,
Wei Huang
=
Hi,
there is no need to apol
Hi,
there is no need to apologize :)
If I understand you correctly, you need access to RuntimeContext within
FlinkTopologyContext. FlinkTopologyContext in created within
StormWrapperSetupHelper.convertToTopologyContext which has already
access to StreamingRuntimeContext (which is just a special
R
Hi Matthias,
Very sorry for the email in weekend.
I try to add a wrapper(FlinkCountMetric) for the Storm-CountMetric and it's
also easy to do it.
But I get a trouble in `FlinkTopologyContext.registerMetric` method that I
don't know how to use the `getRuntimeContext` in this class since I want to
I personally never used Metrics in Storm. It would be best, if you
design an own example.
I guess you are familiar with
https://storm.apache.org/documentation/Metrics.html
As a first step, I would try to include the predefined Storm metric and
work on custom metrics later. As the Storm documentat
Hi Kostas,
Thanks for your support!
I created the JIRA and pushed a PR for it.
@Matthias
Could you give me a storm example in using the cust metrics?
Since it is needed for follow-up development.
Many thanks!
Greetings,
Huang Wei
=
Sounds great. It is easy t
Hi Kostas,
Thank you for the information.
I`ll take a look.
And I`m comparing the storm metrics with Flink accumulators.
I`ll let you know if I have some ideas.
Flink accumulators are documented here:
https://ci.apache.org/projects/flink/flink-docs-master/
Maybe. I did not put any thoughts into this...
On 08/31/2015 12:25 PM, Aljoscha Krettek wrote:
> Hi,
> could the metrics not be implemented on top of Flink accumulators? They
> would even be live-updated in the new web front-end.
>
> Cheers,
> Aljoscha
>
> On Mon, 31 Aug 2015 at 11:32 Matthias J
Hi,
could the metrics not be implemented on top of Flink accumulators? They
would even be live-updated in the new web front-end.
Cheers,
Aljoscha
On Mon, 31 Aug 2015 at 11:32 Matthias J. Sax
wrote:
> Hi,
>
> custom metrics are currently not supported by the compatibility layer.
> See README her
Hi,
custom metrics are currently not supported by the compatibility layer.
See README here:
https://github.com/apache/flink/tree/master/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core
It is an open question, if/how Flink can support this feature.
-Matthias
On 08/31/2015 0
