From 0cac36609a146db7bc2c59c27cf1b5e1d392c6e1 Mon Sep 17 00:00:00 2001 From: Xingjun Wang Date: Mon, 1 Aug 2016 20:30:24 +0800 Subject: [PATCH] fix 2 typos --- .../apache/spark/streaming/scheduler/ReceiverTracker.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala index b9d898a72362..54d0986aa1b9 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala @@ -430,8 +430,8 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false } /** - * Get the receivers from the ReceiverInputDStreams, distributes them to the - * worker nodes as a parallel collection, and runs them. + * Get the receivers from the ReceiverInputDStreams, distribute them to the + * worker nodes as a parallel collection, and run them. */ private def launchReceivers(): Unit = { val receivers = receiverInputStreams.map { nis =>