Here is the assertion error message format: s"Failed to get records for $groupId $topic $partition $offset after polling for $timeout")
You might have to check the kafka service with the error log: > 20/04/10 17:28:04 ERROR Executor: Exception in task 0.5 in stage 0.0 (TID 24) > java.lang.AssertionError: assertion failed: Failed to get records for > spark-executor-service-spark-ingestion dice-ingestion 11 0 after polling for > 120000 Cheers, -z ________________________________________ From: Debabrata Ghosh <mailford...@gmail.com> Sent: Saturday, April 11, 2020 2:25 To: user Subject: Re: Spark Streaming not working Any solution please ? On Fri, Apr 10, 2020 at 11:04 PM Debabrata Ghosh <mailford...@gmail.com<mailto:mailford...@gmail.com>> wrote: Hi, I have a spark streaming application where Kafka is producing records but unfortunately spark streaming isn't able to consume those. I am hitting the following error: 20/04/10 17:28:04 ERROR Executor: Exception in task 0.5 in stage 0.0 (TID 24) java.lang.AssertionError: assertion failed: Failed to get records for spark-executor-service-spark-ingestion dice-ingestion 11 0 after polling for 120000 at scala.Predef$.assert(Predef.scala:170) at org.apache.spark.streaming.kafka010.CachedKafkaConsumer.get(CachedKafkaConsumer.scala:74) at org.apache.spark.streaming.kafka010.KafkaRDD$KafkaRDDIterator.next(KafkaRDD.scala:223) at org.apache.spark.streaming.kafka010.KafkaRDD$KafkaRDDIterator.next(KafkaRDD.scala:189) Would you please be able to help with a resolution. Thanks, Debu --------------------------------------------------------------------- To unsubscribe e-mail: user-unsubscr...@spark.apache.org
