aboutsummaryrefslogtreecommitdiff
path: root/yarn/src/main/scala
diff options
context:
space:
mode:
Diffstat (limited to 'yarn/src/main/scala')
-rw-r--r--yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala
index 7ea58afb53..3f6d7b28b5 100644
--- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala
+++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala
@@ -1138,9 +1138,9 @@ private[spark] class Client(
val pyArchivesFile = new File(pyLibPath, "pyspark.zip")
require(pyArchivesFile.exists(),
"pyspark.zip not found; cannot run pyspark application in YARN mode.")
- val py4jFile = new File(pyLibPath, "py4j-0.9.2-src.zip")
+ val py4jFile = new File(pyLibPath, "py4j-0.10.1-src.zip")
require(py4jFile.exists(),
- "py4j-0.9.2-src.zip not found; cannot run pyspark application in YARN mode.")
+ "py4j-0.10.1-src.zip not found; cannot run pyspark application in YARN mode.")
Seq(pyArchivesFile.getAbsolutePath(), py4jFile.getAbsolutePath())
}
}