Re: Get EOF from PrometheusReporter in JM

2017-10-24 Thread Tony Wei
Hi Max, Good to know. Thanks very much. Best Regards, Tony Wei 2017-10-24 13:52 GMT+08:00 Maximilian Bode : > Hi Tony, > > thanks for troubleshooting this. I have added a commit to > https://github.com/apache/flink/pull/4586 that should enable you to use > the

Re: Get EOF from PrometheusReporter in JM

2017-10-23 Thread Maximilian Bode
Hi Tony, thanks for troubleshooting this. I have added a commit to https://github.com/apache/flink/pull/4586 that should enable you to use the reporter with 1.3.2 as well. Best regards, Max > Tony Wei > 23. September 2017 um 13:11 > Hi Chesnay, > > I built

Re: Get EOF from PrometheusReporter in JM

2017-09-23 Thread Tony Wei
Hi Chesnay, I built another flink cluster using version 1.4, set the log level to DEBUG, and I found that the root cause might be this exception: *java.lang.NullPointerException: Value returned by gauge lastCheckpointExternalPath was null*. I updated `CheckpointStatsTracker` to ignore external

Re: Get EOF from PrometheusReporter in JM

2017-09-22 Thread Tony Wei
Hi Chesnay, I didn't try it in 1.4, so I have no idea if this also occurs in 1.4. For my setting for logging, It have already set to INFO level, but there wasn't any error or warning in log file as well. Best Regards, Tony Wei 2017-09-22 22:07 GMT+08:00 Chesnay Schepler : >

Re: Get EOF from PrometheusReporter in JM

2017-09-22 Thread Chesnay Schepler
The Prometheus reporter should work with 1.3.2. Does this also occur with the reporter that currently exists in 1.4? (to rule out new bugs from the PR). To investigate this further, please set the logging level to WARN and try again, as all errors in the metric system are logged on that

Get EOF from PrometheusReporter in JM

2017-09-22 Thread Tony Wei
Hi, I have built the Prometheus reporter package from this PR https://github.com/apache/flink/pull/4586, and used it on Flink 1.3.2 to record every default metrics and those from `FlinkKafkaConsumer`. Originally, everything was fine. I could get those metrics in TM from Prometheus just like I