[jira] [Resolved] (SPARK-18529) Timeouts shouldn't be AssertionErrors

["Tathagata Das (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SPARK-18529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Tathagata Das resolved SPARK-18529.
-----------------------------------
       Resolution: Fixed
    Fix Version/s: 2.1.0

Issue resolved by pull request 15820
[https://github.com/apache/spark/pull/15820]

> Timeouts shouldn't be AssertionErrors
> -------------------------------------
>
>                 Key: SPARK-18529
>                 URL: https://issues.apache.org/jira/browse/SPARK-18529
>             Project: Spark
>          Issue Type: Bug
>          Components: Structured Streaming
>            Reporter: Michael Armbrust
>            Assignee: Shixiong Zhu
>             Fix For: 2.1.0
>
>
> A timeout should inherit from {{RuntimeException}} as its not a fatal error.
> {code}
> java.lang.AssertionError: assertion failed: Failed to get records for spark-kafka-source-26d6f51c-0781-45a4-ab8e-bc6bd6603917-86874470-executor service-log-0 49350201 after polling for 1000
> 	at scala.Predef$.assert(Predef.scala:170)
> 	at org.apache.spark.sql.kafka010.CachedKafkaConsumer.get(CachedKafkaConsumer.scala:65)
> 	at org.apache.spark.sql.kafka010.KafkaSourceRDD$$anon$1.next(KafkaSourceRDD.scala:146)
> 	at org.apache.spark.sql.kafka010.KafkaSourceRDD$$anon$1.next(KafkaSourceRDD.scala:142)
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org