disable statsd by default for spark (#1089)

Signed-off-by: Oleg Avdeev <[email protected]> Co-authored-by: Oleg Avdeev <[email protected]>
feast-dev · Oct 22, 2020 · 53d16a6 · 53d16a6
1 parent 4141cd0
commit 53d16a6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/spark/ingestion/src/main/scala/feast/ingestion/BasePipeline.scala b/spark/ingestion/src/main/scala/feast/ingestion/BasePipeline.scala
@@ -57,6 +57,7 @@ trait BasePipeline {
           .set("spark.metrics.conf.*.sink.statsd.period", "30")
           .set("spark.metrics.conf.*.sink.statsd.unit", "seconds")
           .set("spark.metrics.namespace", jobConfig.mode.toString)
+      case None => ()
     }
 
     SparkSession

diff --git a/spark/ingestion/src/main/scala/feast/ingestion/IngestionJobConfig.scala b/spark/ingestion/src/main/scala/feast/ingestion/IngestionJobConfig.scala
@@ -101,6 +101,6 @@ case class IngestionJobConfig(
     startTime: DateTime = DateTime.now(),
     endTime: DateTime = DateTime.now(),
     store: StoreConfig = RedisConfig("localhost", 6379, false),
-    metrics: Option[MetricConfig] = Some(StatsDConfig("localhost", 9125)),
+    metrics: Option[MetricConfig] = None,
     deadLetterPath: Option[String] = None
 )