File tree Expand file tree Collapse file tree 1 file changed +2
-6
lines changed
streaming/src/main/scala/org/apache/spark/streaming Expand file tree Collapse file tree 1 file changed +2
-6
lines changed Original file line number Diff line number Diff line change @@ -575,9 +575,7 @@ class StreamingContext private[streaming] (
575575 * @throws IllegalStateException if the StreamingContext is already stopped.
576576 */
577577 def start (): Unit = synchronized {
578- /**
579- * Registering Streaming Metrics at the start of the StreamingContext
580- */
578+ // Registering Streaming Metrics at the start of the StreamingContext
581579 assert(env != null )
582580 assert(env.metricsSystem != null )
583581 env.metricsSystem.registerSource(streamingSource)
@@ -692,9 +690,7 @@ class StreamingContext private[streaming] (
692690 } finally {
693691 // The state should always be Stopped after calling `stop()`, even if we haven't started yet
694692 state = STOPPED
695- /**
696- * De-registering Streaming Metrics at the stop of the StreamingContext
697- */
693+ // De-registering Streaming Metrics of the StreamingContext
698694 env.metricsSystem.removeSource(streamingSource)
699695 }
700696 }
You can’t perform that action at this time.
0 commit comments