add @transient to metric source lazy val

pyalex · pyalex · commit a71ed6a76bde · 2021-04-30T17:48:01.000+08:00
Signed-off-by: Oleksii Moskalenko &lt;moskalenko.alexey@gmail.com&gt;
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)

Original file line number	Diff line number	Diff line change
`@@ -192,6 +192,7 @@ object BigTableSinkRelation {`
`192`	`192`	`(null, put)`
`193`	`193`	`}`
`194`	`194`
	`195`	`+ @transient`
`195`	`196`	`lazy val metricSource: Option[BigTableSinkMetricSource] = {`
`196`	`197`	`if (SparkEnv.get.metricsSystem.getSourcesByName(BigTableSinkMetricSource.sourceName).isEmpty) {`
`197`	`198`	`SparkEnv.get.metricsSystem.registerSource(new BigTableSinkMetricSource)`