[SPARK-18529] Timeouts shouldn't be AssertionErrors

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.1.0
• Component/s: Structured Streaming
• Target Version/s: 2.1.0
• Assignee: Shixiong Zhu
• Reporter: Michael Armbrust
• Created: 21/Nov/16 17:32
• Updated: 22/Nov/16 22:17
• Resolved: 22/Nov/16 22:17

Description

A timeout should inherit from RuntimeException as its not a fatal error.

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)

Issue Links

• links to: [Github] Pull Request #15820 (zsxwing)