explicitly visit spark env 3

2018-05-16 18:58:23 +08:00 · 2018-05-16 18:58:23 +08:00 · 52c5efb9ed
commit 52c5efb9ed
parent 7809facd12
1 changed files with 1 additions and 1 deletions
--- a/src/main/scala/org/apache/spark/KyuubiSparkUtil.scala
+++ b/src/main/scala/org/apache/spark/KyuubiSparkUtil.scala
@ -79,7 +79,7 @@ object KyuubiSparkUtil extends Logging {
    val classLoader = new KyuubiFirstClassLoader(Array(url), getContextOrSparkClassLoader())
    val envCls = classLoader.loadClass("org.apache.spark.SparkEnv", true)
    val envObj = classLoader.loadClass("org.apache.spark.SparkEnv$", true)
-    ReflectUtils.invokeStaticMethod(envObj, "set", Seq(envCls), null)
+    ReflectUtils.invokeStaticMethod(envCls, "set", Seq(envCls), null)
    classLoader
  }