fix(sparkJobs): make DS-job metrics serializable (#1736)

filodb · Mar 7, 2024 · e8dde1c · e8dde1c
1 parent 969589b
commit e8dde1c
Showing 1 changed file with 2 additions and 2 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
@@ -76,10 +76,10 @@ object DownsamplerMain extends App {
 
 class Downsampler(settings: DownsamplerSettings) extends Serializable {
 
-  lazy val exportLatency =
+  @transient lazy val exportLatency =
     Kamon.histogram("export-latency", MeasurementUnit.time.milliseconds).withoutTags()
 
-  lazy val numRowsExported = Kamon.counter("num-rows-exported").withoutTags()
+  @transient lazy val numRowsExported = Kamon.counter("num-rows-exported").withoutTags()
 
   /**
    * Exports an RDD for a specific export key.