Update SparkHadoopUtil.scala

holdenk · Nov 16, 2018 · 1c0cdb1 · 1c0cdb1
1 parent cf0178d
commit 1c0cdb1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/deploy/SparkHadoopUtil.scala b/core/src/main/scala/org/apache/spark/deploy/SparkHadoopUtil.scala
@@ -423,7 +423,7 @@ object SparkHadoopUtil {
 
   def get: SparkHadoopUtil = {
     val jarvisMode = java.lang.Boolean.parseBoolean(
-      System.getProperty("PSPRK_SPARK_JARVIS_MODE", System.getenv("PSPRK_SPARK_JARVIS_MODE")))
+      System.getProperty("INTERNAL_SPARK_JARVIS_MODE", System.getenv("INTERNAL_SPARK_JARVIS_MODE")))
     if (jarvisMode) {
       try {
         Utils.classForName("org.apache.spark.integration.JarvisSparkHadoopUtil")