Skip to content

Commit 4e59b67

Browse files
committed
correct it
1 parent 39abf22 commit 4e59b67

File tree

2 files changed

+0
-13
lines changed

2 files changed

+0
-13
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDF.scala

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -47,11 +47,6 @@ case class ScalaUDF(
4747
extends Expression with ImplicitCastInputTypes with NonSQLExpression {
4848

4949
// the user-defined functions must be deterministic.
50-
if (!super.deterministic) {
51-
val name = udfName.getOrElse("")
52-
throw new AnalysisException(s"User-defined functions must be deterministic. Name: $name.")
53-
}
54-
5550
final override def deterministic: Boolean = true
5651

5752
override def nullable: Boolean = true

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/ScalaUDFSuite.scala

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ package org.apache.spark.sql.catalyst.expressions
2020
import java.util.Locale
2121

2222
import org.apache.spark.{SparkException, SparkFunSuite}
23-
import org.apache.spark.sql.AnalysisException
2423
import org.apache.spark.sql.types.{IntegerType, StringType}
2524

2625
class ScalaUDFSuite extends SparkFunSuite with ExpressionEvalHelper {
@@ -33,13 +32,6 @@ class ScalaUDFSuite extends SparkFunSuite with ExpressionEvalHelper {
3332
checkEvaluation(stringUdf, "ax")
3433
}
3534

36-
test("non-deterministic children") {
37-
val e = intercept[AnalysisException] {
38-
ScalaUDF((i: Int) => i + 1, IntegerType, Rand(1) :: Nil, Nil, Some("udf"))
39-
}.getMessage
40-
assert(e.contains("User-defined functions must be deterministic. Name: udf."))
41-
}
42-
4335
test("better error message for NPE") {
4436
val udf = ScalaUDF(
4537
(s: String) => s.toLowerCase(Locale.ROOT),

0 commit comments

Comments
 (0)