diff --git a/spark-jobs/src/main/scala/filodb/downsampler/chunk/DownsamplerMain.scala b/spark-jobs/src/main/scala/filodb/downsampler/chunk/DownsamplerMain.scala index da87071cdc..88c24c1290 100644 --- 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 index d7024d4298..21d741295a 100644 --- 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")