From 4b8402e900c803e64b8a4e2094fd845ccfc9df36 Mon Sep 17 00:00:00 2001
From: Tathagata Das <tathagata.das1565@gmail.com>
Date: Thu, 14 Feb 2013 18:10:37 -0800
Subject: [PATCH] Moved Java streaming examples to
examples/src/main/java/spark/streaming/... and fixed logging in
NetworkInputTracker to highlight errors when receiver deregisters/shuts down.
---
.../spark/streaming/examples/JavaFlumeEventCount.java | 0
.../spark/streaming/examples/JavaNetworkWordCount.java | 0
.../spark/streaming/examples/JavaQueueStream.java | 0
.../src/main/scala/spark/streaming/NetworkInputTracker.scala | 2 +-
4 files changed, 1 insertion(+), 1 deletion(-)
rename examples/src/main/{scala => java}/spark/streaming/examples/JavaFlumeEventCount.java (100%)
rename examples/src/main/{scala => java}/spark/streaming/examples/JavaNetworkWordCount.java (100%)
rename examples/src/main/{scala => java}/spark/streaming/examples/JavaQueueStream.java (100%)
diff --git a/examples/src/main/scala/spark/streaming/examples/JavaFlumeEventCount.java b/examples/src/main/java/spark/streaming/examples/JavaFlumeEventCount.java
similarity index 100%
rename from examples/src/main/scala/spark/streaming/examples/JavaFlumeEventCount.java
rename to examples/src/main/java/spark/streaming/examples/JavaFlumeEventCount.java
diff --git a/examples/src/main/scala/spark/streaming/examples/JavaNetworkWordCount.java b/examples/src/main/java/spark/streaming/examples/JavaNetworkWordCount.java
similarity index 100%
rename from examples/src/main/scala/spark/streaming/examples/JavaNetworkWordCount.java
rename to examples/src/main/java/spark/streaming/examples/JavaNetworkWordCount.java
diff --git a/examples/src/main/scala/spark/streaming/examples/JavaQueueStream.java b/examples/src/main/java/spark/streaming/examples/JavaQueueStream.java
similarity index 100%
rename from examples/src/main/scala/spark/streaming/examples/JavaQueueStream.java
rename to examples/src/main/java/spark/streaming/examples/JavaQueueStream.java
diff --git a/streaming/src/main/scala/spark/streaming/NetworkInputTracker.scala b/streaming/src/main/scala/spark/streaming/NetworkInputTracker.scala
index b54f53b203..ca5f11fdba 100644
--- a/streaming/src/main/scala/spark/streaming/NetworkInputTracker.scala
+++ b/streaming/src/main/scala/spark/streaming/NetworkInputTracker.scala
@@ -86,7 +86,7 @@ class NetworkInputTracker(
}
case DeregisterReceiver(streamId, msg) => {
receiverInfo -= streamId
- logInfo("De-registered receiver for network stream " + streamId
+ logError("De-registered receiver for network stream " + streamId
+ " with message " + msg)
//TODO: Do something about the corresponding NetworkInputDStream
}
--
GitLab