You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/01/08 07:22:08 UTC
[06/13] git commit: Removed extra empty lines.
Removed extra empty lines.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/87b915f2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/87b915f2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/87b915f2
Branch: refs/heads/master
Commit: 87b915f22105ced8b9cad2a1262a0fd26542ee4f
Parents: 3ab297a
Author: Tathagata Das <ta...@gmail.com>
Authored: Tue Dec 31 00:42:10 2013 -0800
Committer: Tathagata Das <ta...@gmail.com>
Committed: Tue Dec 31 00:42:10 2013 -0800
----------------------------------------------------------------------
.../scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala | 1 -
.../org/apache/spark/streaming/twitter/TwitterInputDStream.scala | 1 -
.../org/apache/spark/streaming/scheduler/NetworkInputTracker.scala | 1 -
3 files changed, 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/87b915f2/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala
----------------------------------------------------------------------
diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala
index fd69328..a2cd49c 100644
--- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala
+++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala
@@ -34,7 +34,6 @@ import org.apache.spark.storage.StorageLevel
import org.apache.spark.streaming.StreamingContext
import org.apache.spark.streaming.dstream._
-
/**
* Input stream that pulls messages from a Kafka Broker.
*
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/87b915f2/external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala
----------------------------------------------------------------------
diff --git a/external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala b/external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala
index 97e48eb..5cc721d 100644
--- a/external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala
+++ b/external/twitter/src/main/scala/org/apache/spark/streaming/twitter/TwitterInputDStream.scala
@@ -98,4 +98,3 @@ class TwitterReceiver(
logInfo("Twitter receiver stopped")
}
}
-
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/87b915f2/streaming/src/main/scala/org/apache/spark/streaming/scheduler/NetworkInputTracker.scala
----------------------------------------------------------------------
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/NetworkInputTracker.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/NetworkInputTracker.scala
index 4a8e15d..75f7244 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/NetworkInputTracker.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/NetworkInputTracker.scala
@@ -164,7 +164,6 @@ class NetworkInputTracker(
ssc.sparkContext.makeRDD(1 to 50, 50).map(x => (x, 1)).reduceByKey(_ + _, 20).collect()
}
-
// Distribute the receivers and start them
ssc.sparkContext.runJob(tempRDD, startReceiver)
}