add @transient to metric source lazy val

Signed-off-by: Oleksii Moskalenko <moskalenko.alexey@gmail.com>
feast-dev · Apr 30, 2021 · a71ed6a · a71ed6a
1 parent 6d5943c
commit a71ed6a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/spark/ingestion/src/main/scala/feast/ingestion/stores/bigtable/BigTableSinkRelation.scala b/spark/ingestion/src/main/scala/feast/ingestion/stores/bigtable/BigTableSinkRelation.scala
@@ -192,6 +192,7 @@ object BigTableSinkRelation {
       (null, put)
     }
 
+  @transient
   lazy val metricSource: Option[BigTableSinkMetricSource] = {
     if (SparkEnv.get.metricsSystem.getSourcesByName(BigTableSinkMetricSource.sourceName).isEmpty) {
       SparkEnv.get.metricsSystem.registerSource(new BigTableSinkMetricSource)