Skip to content

Commit cb7e97a

Browse files
committed
update error message
1 parent e848ec7 commit cb7e97a

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/ScalaReflection.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -943,9 +943,9 @@ trait ScalaReflection extends Logging {
943943
*/
944944
def getParameterTypeNullability(func: AnyRef): Seq[Boolean] = {
945945
if (!Properties.versionString.contains("2.11")) {
946-
logWarning(s"Scala ${Properties.versionString} is not supported so UDF input parameter "
947-
+ s"type nullability may be inferred incorrectly. To avoid this problem, use the "
948-
+ s"latest UDF interfaces instead.")
946+
logWarning(s"Scala ${Properties.versionString} cannot get type nullability correctly via " +
947+
"reflection, thus Spark cannot add proper input null check for UDF. To avoid this " +
948+
"problem, use the typed UDF interfaces instead.")
949949
}
950950
val methods = func.getClass.getMethods.filter(m => m.getName == "apply" && !m.isBridge)
951951
assert(methods.length == 1)

0 commit comments

Comments
 (0)