Skip to content

Commit 709ac1f

Browse files
committed
Fix the comment
1 parent e103e8a commit 709ac1f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTracker.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -280,7 +280,7 @@ class ReceiverTracker(ssc: StreamingContext, skipReceiverLaunch: Boolean = false
280280
context.reply(true)
281281
}
282282

283-
/** Stops the receivers. */
283+
/** Send stop signal to the receivers. */
284284
private def stopReceivers() {
285285
// Signal the receivers to stop
286286
receiverInfo.values.flatMap { info => Option(info.endpoint)}

0 commit comments

Comments
 (0)