Thanks for the heads up! I'm glad you figured it out.
On Sun, Apr 17, 2016, 13:35 neo21 zerro wrote:
> Nevermind, I've figured it out.
> I was skipping the tuples that were coming from kafka based on some custom
> login.
> That custom logic made sure that the kafka operator did not emit any
> tu
Nevermind, I've figured it out.
I was skipping the tuples that were coming from kafka based on some custom
login.
That custom logic made sure that the kafka operator did not emit any tuples.
Hence, the missing metrics in the flink ui.
On Thursday, April 14, 2016 1:12 AM, neo21 zerro wrote:
Hello everybody,
I have deployed the latest Flink Version 1.0.1 on Yarn 2.5.0-cdh5.3.0.
When I push the WordCount example shipped with the Flink distribution, I can
see metrics (bytes received) in the Flink Ui on the corresponding operator.
However, I used the flink kafka connector and when I r
