Skip to content

Commit

Permalink
update error message
Browse files Browse the repository at this point in the history
  • Loading branch information
cloud-fan committed Oct 19, 2018
1 parent e848ec7 commit cb7e97a
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -943,9 +943,9 @@ trait ScalaReflection extends Logging {
*/
def getParameterTypeNullability(func: AnyRef): Seq[Boolean] = {
if (!Properties.versionString.contains("2.11")) {
logWarning(s"Scala ${Properties.versionString} is not supported so UDF input parameter "
+ s"type nullability may be inferred incorrectly. To avoid this problem, use the "
+ s"latest UDF interfaces instead.")
logWarning(s"Scala ${Properties.versionString} cannot get type nullability correctly via " +
"reflection, thus Spark cannot add proper input null check for UDF. To avoid this " +
"problem, use the typed UDF interfaces instead.")
}
val methods = func.getClass.getMethods.filter(m => m.getName == "apply" && !m.isBridge)
assert(methods.length == 1)
Expand Down

0 comments on commit cb7e97a

Please sign in to comment.