When I create a pipeline in CDAP studio / data fusion and add a dynamic spark transformation with spark scala code inside. A simple ``` def transform(df: DataFrame) : DataFrame = { df } ``` Fails the validation. The validation error is: ``` Errors org.apache.spark.api.java.function.Function ``` What is the problem? thanks!