Re: Spark Stream Monitoring with Kafka Direct API

2015-12-09 Thread Saisai Shao
I think this is the right JIRA to fix this issue ( https://issues.apache.org/jira/browse/SPARK-7111). It should be in Spark 1.4. On Thu, Dec 10, 2015 at 12:32 AM, Cody Koeninger wrote: > Looks like probably > > https://issues.apache.org/jira/browse/SPARK-8701 > > so 1.5.0 > > On Wed, Dec 9, 2015

Re: Spark Stream Monitoring with Kafka Direct API

2015-12-09 Thread Dan Dutrow
I'm on spark version 1.4.1. I couldn't find documentation that said it was fixed, so I thought maybe it was still an open issue. Any idea what the fix version is? On Wed, Dec 9, 2015 at 11:10 AM Cody Koeninger wrote: > Which version of spark are you on? I thought that was added to the spark > U

Re: Spark Stream Monitoring with Kafka Direct API

2015-12-09 Thread Cody Koeninger
Looks like probably https://issues.apache.org/jira/browse/SPARK-8701 so 1.5.0 On Wed, Dec 9, 2015 at 10:25 AM, Dan Dutrow wrote: > I'm on spark version 1.4.1. I couldn't find documentation that said it was > fixed, so I thought maybe it was still an open issue. Any idea what the fix > version

Re: Spark Stream Monitoring with Kafka Direct API

2015-12-09 Thread Cody Koeninger
Which version of spark are you on? I thought that was added to the spark UI in recent versions. DIrect api doesn't have any inherent interaction with zookeeper. If you need number of messages per batch and aren't on a recent enough version of spark to see them in the ui, you can get them program

Spark Stream Monitoring with Kafka Direct API

2015-12-09 Thread Dan Dutrow
Is there documentation for how to update the metrics (#messages per batch) in the Spark Streaming tab when using the Direct API? Does the Streaming tab get its information from Zookeeper or something else internally? -- Dan ✆