Skip to content

Commit 4754125

Browse files
committed
Add an instruction for failOnDataLoss
1 parent 7d658f1 commit 4754125

File tree

1 file changed

+2
-1
lines changed
  • external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010

1 file changed

+2
-1
lines changed

external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -332,7 +332,8 @@ private[kafka010] case class KafkaSource(
332332
*/
333333
private def reportDataLoss(message: String): Unit = {
334334
if (failOnDataLoss) {
335-
throw new IllegalStateException(message)
335+
throw new IllegalStateException(message +
336+
". Set the source option 'failOnDataLoss' to 'false' if you want to ignore these checks.")
336337
} else {
337338
logWarning(message)
338339
}

0 commit comments

Comments
 (0)