We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a665965 commit 7621adfCopy full SHA for 7621adf
streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala
@@ -575,7 +575,7 @@ class StreamingContext private[streaming] (
575
* @throws IllegalStateException if the StreamingContext is already stopped.
576
*/
577
def start(): Unit = synchronized {
578
- //Registering Streaming Metrics at the start of the StreamingContext
+ // Registering Streaming Metrics at the start of the StreamingContext
579
assert(env != null)
580
assert(env.metricsSystem != null)
581
env.metricsSystem.registerSource(streamingSource)
0 commit comments