Skip to content
Snippets Groups Projects
Commit 0a7a94ea authored by jerluc's avatar jerluc Committed by Tathagata Das
Browse files

[SPARK-7621] [STREAMING] Report Kafka errors to StreamingListeners

PR per [SPARK-7621](https://issues.apache.org/jira/browse/SPARK-7621), which makes both `KafkaReceiver` and `ReliableKafkaReceiver` report its errors to the `ReceiverTracker`, which in turn will add the events to the bus to fire off any registered `StreamingListener`s.

Author: jerluc <jeremyalucas@gmail.com>

Closes #6204 from jerluc/master and squashes the following commits:

82439a5 [jerluc] [SPARK-7621] [STREAMING] Report Kafka errors to StreamingListeners
parent 4fb52f95
No related branches found
No related tags found
No related merge requests found
...@@ -135,7 +135,7 @@ class KafkaReceiver[ ...@@ -135,7 +135,7 @@ class KafkaReceiver[
store((msgAndMetadata.key, msgAndMetadata.message)) store((msgAndMetadata.key, msgAndMetadata.message))
} }
} catch { } catch {
case e: Throwable => logError("Error handling message; exiting", e) case e: Throwable => reportError("Error handling message; exiting", e)
} }
} }
} }
......
...@@ -267,7 +267,7 @@ class ReliableKafkaReceiver[ ...@@ -267,7 +267,7 @@ class ReliableKafkaReceiver[
} }
} catch { } catch {
case e: Exception => case e: Exception =>
logError("Error handling message", e) reportError("Error handling message", e)
} }
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment