Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/22106#discussion_r210383608
--- Diff:
external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaContinuousReader.scala
---
@@ -216,7 +216,7 @@ class KafkaContinuousInputPartitionReader(
} catch {
// We didn't read within the timeout. We're supposed to block
indefinitely for new data, so
// swallow and ignore this.
- case _: TimeoutException =>
+ case _: TimeoutException | _:
org.apache.kafka.common.errors.TimeoutException =>
--- End diff --
This is to fix
https://amplab.cs.berkeley.edu/jenkins/job/NewSparkPullRequestBuilder/4254/
`org.apache.kafka.common.errors.TimeoutException: Timeout of 3000ms expired
before the position for partition failOnDataLoss-2-0 could be determined`
triggered a task retry but as continuous processing doesn't support task
retries, it failed with
`org.apache.spark.sql.execution.streaming.continuous.ContinuousTaskRetryException:
Continuous execution does not support task retry`.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
