diff --git a/streaming/src/main/scala/org/apache/spark/streaming/StreamingSource.scala b/streaming/src/main/scala/org/apache/spark/streaming/StreamingSource.scala
index 0b306a28d1a59..793dfbb979511 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/StreamingSource.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/StreamingSource.scala
@@ -24,7 +24,7 @@ import org.apache.spark.streaming.ui.StreamingJobProgressListener
 
 private[streaming] class StreamingSource(ssc: StreamingContext) extends Source {
   override val metricRegistry = new MetricRegistry
-  override val sourceName = "%s.StreamingMetrics".format(ssc.sparkContext.appName)
+  override val sourceName = "StreamingMetrics"
 
   private val streamingListener = ssc.progressListener