[SPARK-40506]Spark Streaming metrics name doesn't need application name

beryllw · Sep 20, 2022 · 82cd4a0 · 82cd4a0
1 parent e021f8b
commit 82cd4a0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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