File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
core/src/main/scala/org/apache/spark/util Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -2489,8 +2489,10 @@ private[spark] class CallerContext(
24892489 def setCurrentContext (): Boolean = {
24902490 var succeed = false
24912491 try {
2492- val callerContext = Utils .classForName(" org.apache.hadoop.ipc.CallerContext" )
2493- val Builder = Utils .classForName(" org.apache.hadoop.ipc.CallerContext$Builder" )
2492+ // scalastyle:off classforname
2493+ val callerContext = Class .forName(" org.apache.hadoop.ipc.CallerContext" )
2494+ val Builder = Class .forName(" org.apache.hadoop.ipc.CallerContext$Builder" )
2495+ // scalastyle:on classforname
24942496 val builderInst = Builder .getConstructor(classOf [String ]).newInstance(context)
24952497 val hdfsContext = Builder .getMethod(" build" ).invoke(builderInst)
24962498 callerContext.getMethod(" setCurrent" , callerContext).invoke(null , hdfsContext)
You can’t perform that action at this time.
0 commit comments