diff --git a/feathr-impl/src/main/scala/com/linkedin/feathr/swj/aggregate/DistinctAggregate.scala b/feathr-impl/src/main/scala/com/linkedin/feathr/swj/aggregate/DistinctAggregate.scala index f806c4a8d..2d6bb53a6 100644 --- a/feathr-impl/src/main/scala/com/linkedin/feathr/swj/aggregate/DistinctAggregate.scala +++ b/feathr-impl/src/main/scala/com/linkedin/feathr/swj/aggregate/DistinctAggregate.scala @@ -6,7 +6,7 @@ import org.apache.spark.sql.types._ import scala.collection.mutable import scala.collection.mutable.ArrayBuffer -/* +/** * DISTINCT aggregation implementation. * * @param metricCol Name of the metric column or a Spark SQL column expression for derived metric diff --git a/feathr-impl/src/test/scala/com/linkedin/feathr/offline/AssertFeatureUtils.scala b/feathr-impl/src/test/scala/com/linkedin/feathr/offline/AssertFeatureUtils.scala index 147d2df7f..dfc3f3796 100644 --- a/feathr-impl/src/test/scala/com/linkedin/feathr/offline/AssertFeatureUtils.scala +++ b/feathr-impl/src/test/scala/com/linkedin/feathr/offline/AssertFeatureUtils.scala @@ -198,6 +198,7 @@ object AssertFeatureUtils { } else if(field.dataType == ArrayType(StringType, false)) { assertStringArrayEquals(actualValue.asInstanceOf[Array[String]], expectedValue.asInstanceOf[Array[String]]) } else { + } } }