I have a similar issue. I raised a JIRA :
 https://issues.apache.org/jira/browse/FLINK-11198
Thanks,
Chirag
   On Wednesday, 19 December, 2018, 11:35:02 AM IST, Fabian Hueske 
<fhue...@gmail.com> wrote: 
 
 Hi,
AFAIK it is not possible to collect metrics for an AggregateFunction.You can 
open a feature request by creating a Jira issue.

Thanks, 
Fabian


Am Mo., 17. Dez. 2018 um 21:29 Uhr schrieb Gaurav Luthra 
<gauravluthra6...@gmail.com>:

Hi,
I need to know the way to implement custom metrics in my flink 
program.Currently, I know we can create custom metrics with the help of 
RuntimeContext. But in my aggregate() I do not have RuntimeContext. I am using 
window operator and applying aggregate() method on it. And I am passing 
AggregateFunction in aggregate() method.
So, Kindly guide me, how can I create custom metrics in my code?
Note: As we know we can not user RichAggregateFunction with aggregate() method 
Thanks & RegardsGaurav LuthraMob:- +91-9901945206
  

Reply via email to