Re: [E] Re: Pyspark Kafka Structured Stream not working.

2020-05-07 Thread Jungtaek Lim
It's not either 1 or 2. Both two items are applied. I haven't played with DStream + pyspark but given the error message is clear you'll probably want to change the client.id "Python Kafka streamer" to accommodate the naming convention guided in error message. On Thu, May 7, 2020 at 3:55 PM Vijayan

RE: [E] Re: Pyspark Kafka Structured Stream not working.

2020-05-06 Thread Vijayant Kumar
Hi Jungtek, Thanks for the response. It appears to be #1. I will appreciate if you can share some sample command to submit the Spark application.? From: Jungtaek Lim [mailto:kabhwan.opensou...@gmail.com] Sent: Wednesday, May 06, 2020 8:24 PM To: Vijayant Kumar Cc: user@spark.apache.org Subject: