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
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