Re: Kafka direct approach,App UI shows wrong input rate

2016-11-22 Thread Julian Keppel
Oh, sorry. I made a mistake... It's spark version 2.0.1, not 2.0.2. When I wrote the initial message I built my app with 2.0.2 and deployed it on a cluster with 2.0.1. So I thought this could be the problem. But now I changed it and build my app with 2.0.1 but the problem still remains.

Re: Kafka direct approach,App UI shows wrong input rate

2016-11-19 Thread Cody Koeninger
There have definitely been issues with UI reporting for the direct stream in the past, but I'm not able to reproduce this with 2.0.2 and 0.8. See below: https://i.imgsafe.org/086019ae57.png On Fri, Nov 18, 2016 at 4:38 AM, Julian Keppel wrote: > Hello, > > I use

Kafka direct approach,App UI shows wrong input rate

2016-11-18 Thread Julian Keppel
Hello, I use Spark 2.0.2 with Kafka integration 0-8. The Kafka version is 0.10.0.1 (Scala 2.11). I read data from Kafka with the direct approach. The complete infrastructure runs on Google Container Engine. I wonder why the corresponding application UI says the input rate is zero records per