diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala index 228f4b756c8b..88525cd6e4cd 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala @@ -45,6 +45,9 @@ case class ScalaUDF( udfName: Option[String] = None) extends Expression with ImplicitCastInputTypes with NonSQLExpression { + // the user-defined functions must be deterministic. + final override def deterministic: Boolean = true + override def nullable: Boolean = true override def toString: String =