Skip to content
Snippets Groups Projects
Commit 4b8402e9 authored by Tathagata Das's avatar Tathagata Das
Browse files

Moved Java streaming examples to examples/src/main/java/spark/streaming/......

Moved Java streaming examples to examples/src/main/java/spark/streaming/... and fixed logging in NetworkInputTracker to highlight errors when receiver deregisters/shuts down.
parent def8126d
No related branches found
No related tags found
No related merge requests found
...@@ -86,7 +86,7 @@ class NetworkInputTracker( ...@@ -86,7 +86,7 @@ class NetworkInputTracker(
} }
case DeregisterReceiver(streamId, msg) => { case DeregisterReceiver(streamId, msg) => {
receiverInfo -= streamId receiverInfo -= streamId
logInfo("De-registered receiver for network stream " + streamId logError("De-registered receiver for network stream " + streamId
+ " with message " + msg) + " with message " + msg)
//TODO: Do something about the corresponding NetworkInputDStream //TODO: Do something about the corresponding NetworkInputDStream
} }
......
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