Hi,
Could you provide with the code snippet of how you are connecting and
reading data from kafka?
Akshay Bhardwaj
+91-97111-33849
On Thu, Oct 17, 2019 at 8:39 PM Amit Sharma wrote:
> Please update me if any one knows about it.
>
>
> Thanks
> Amit
>
> On Thu, Oct 10, 2019 at 3:49 PM Amit
Please update me if any one knows about it.
Thanks
Amit
On Thu, Oct 10, 2019 at 3:49 PM Amit Sharma wrote:
> Hi , we have spark streaming job to which we send a request through our UI
> using kafka. It process and returned the response. We are getting below
> error and this stareming is not
Hi , we have spark streaming job to which we send a request through our UI
using kafka. It process and returned the response. We are getting below
error and this stareming is not processing any request.
Listener StreamingJobProgressListener threw an exception
java.util.NoSuchElementException: key
As we increase the throughput on our Spark streaming application, we're finding
we hit errors with the WriteAheadLog, with errors like this:
16/05/21 20:42:21 WARN scheduler.ReceivedBlockTracker: Exception thrown while
writing record:
Hi All,
I came across the related old conversation on the above issue (
https://issues.apache.org/jira/browse/SPARK-5594. ) Is the issue fixed? I
tried different values for spark.cleaner.ttl -> 0sec, -1sec,
2000sec,..none of them worked. I also tried setting
spark.streaming.unpersist -> true.
Hello All,
When I push messages into kafka and read into streaming application, I see
the following exception-
I am running the application on YARN and no where broadcasting the message
within the application. Just simply reading message, parsing it and
populating fields in a class and then
