diff --git a/src/main/scala/org/globalforestwatch/summarystats/forest_change_diagnostic/ForestChangeDiagnosticCommand.scala b/src/main/scala/org/globalforestwatch/summarystats/forest_change_diagnostic/ForestChangeDiagnosticCommand.scala index 7747d33c..22be3a9c 100644 --- a/src/main/scala/org/globalforestwatch/summarystats/forest_change_diagnostic/ForestChangeDiagnosticCommand.scala +++ b/src/main/scala/org/globalforestwatch/summarystats/forest_change_diagnostic/ForestChangeDiagnosticCommand.scala @@ -36,11 +36,10 @@ object ForestChangeDiagnosticCommand extends SummaryCommand with LazyLogging { "config" -> GfwConfig.get ) - if (!default.splitFeatures) logger.warn("Forcing splitFeatures = true") val featureFilter = FeatureFilter.fromOptions(default.featureType, filterOptions) runAnalysis { implicit spark => - val featureRDD = ValidatedFeatureRDD(default.featureUris, default.featureType, featureFilter, splitFeatures = true) + val featureRDD = ValidatedFeatureRDD(default.featureUris, default.featureType, featureFilter, splitFeatures = false) val fireAlertRDD = FireAlertRDD(spark, fireAlert.alertType, fireAlert.alertSource, FeatureFilter.empty) val intermediateResultsRDD = intermediateListSource.map { sources =>