misc(sparkjobs): publish additional metric with no tags for successfu…

…l completion (filodb#1711)
sandeep6189 · Feb 29, 2024 · 19d8ed9 · 19d8ed9
1 parent 44736cb
commit 19d8ed9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/spark-jobs/src/main/scala/filodb/downsampler/chunk/DownsamplerMain.scala b/spark-jobs/src/main/scala/filodb/downsampler/chunk/DownsamplerMain.scala
@@ -183,7 +183,9 @@ class Downsampler(settings: DownsamplerSettings) extends Serializable {
       s"$downsamplePeriodStr")
     val jobCompleted = Kamon.counter("chunk-migration-completed")
       .withTag("downsamplePeriod", downsamplePeriodStr)
+    val jobCompletedNoTags = Kamon.counter("chunk-migration-completed-success").withoutTags()
     jobCompleted.increment()
+    jobCompletedNoTags.increment()
     val downsampleHourStartGauge = Kamon.gauge("chunk-downsampler-period-start-hour")
       .withTag("downsamplePeriod", downsamplePeriodStr)
     downsampleHourStartGauge.update(userTimeStart / 1000 / 60 / 60)

diff --git a/spark-jobs/src/main/scala/filodb/downsampler/index/DSIndexJobMain.scala b/spark-jobs/src/main/scala/filodb/downsampler/index/DSIndexJobMain.scala
@@ -113,7 +113,9 @@ class IndexJobDriver(dsSettings: DownsamplerSettings, dsIndexJobSettings: DSInde
     DownsamplerContext.dsLogger.info(s"Index Downsampling Driver completed successfully for downsample period " +
       s"$downsamplePeriodStr doFullMigration=$doFullMigration")
     val jobCompleted = Kamon.counter("index-migration-completed").withTag("downsamplePeriod", downsamplePeriodStr)
+    val jobCompletedNoTags = Kamon.counter("index-migration-completed-success").withoutTags()
     jobCompleted.increment()
+    jobCompletedNoTags.increment()
 
     if (!doFullMigration) {
       val downsampleHourStartGauge = Kamon.gauge("index-downsampler-period-start-hour")