I'm using Spark 2.0.2 and running a structured streaming query. When I
set startingOffsets
to earliest I get the following timeout errors:
java.lang.AssertionError: assertion failed: Failed to get records for
spark-kafka-source-be89d84c-f6e9-4d2b-b6cd-570942dc7d5d-185814897-executor
my-favorite-topic-0 1127918 after polling for 2048
I do not get these errors when I set startingOffsets to latest.
Timothy Chan 's gravatar image asked Jan 11 2017 at 11:05 in Spark-User by Timothy Chan

0 Answers

Facebook Google+ Twitter Linkedin
 Discussion Overview

 Group: Spark-user

 asked: Jan 11 2017 at 11:05

 active: Jan 11 2017 at 11:05

 posts: 1

 users: 1

Related Groups
Spark-dev
Spark-user