hbgstc123 commented on issue #6540:
URL: https://github.com/apache/hudi/issues/6540#issuecomment-1231829249
` override def getRegistration(klass: Class[_]) =
if (isJavaLambda(klass)) {
getClassResolver.getRegistration(classOf[ClosureSerializer.Closure])
} else super.getRegistration(klass)`
This may be a flink problem, in com.twitter.chill.KryoBase, if the above
code enter first branch, it will try to get serializer from a map in
classResolver and not checking if the result is null, then it may cause a NPE.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
