Skip to content

Commit 7989b56

Browse files
author
Andrew Or
committed
Add huge compatibility warning
1 parent e945aa6 commit 7989b56

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

core/src/main/scala/org/apache/spark/deploy/worker/DriverWrapper.scala

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,10 +26,17 @@ import org.apache.spark.util.{AkkaUtils, ChildFirstURLClassLoader, MutableURLCla
2626

2727
/**
2828
* Utility object for launching driver programs such that they share fate with the Worker process.
29+
* This is used in standalone cluster mode only.
2930
*/
3031
object DriverWrapper {
3132
def main(args: Array[String]) {
3233
args.toList match {
34+
/*
35+
* IMPORTANT: Spark 1.3 provides a stable application submission gateway that is both
36+
* backward and forward compatible across future Spark versions. Because this gateway
37+
* uses this class to launch the driver, the ordering and semantics of the arguments
38+
* here must also remain consistent across versions.
39+
*/
3340
case workerUrl :: userJar :: mainClass :: extraArgs =>
3441
val conf = new SparkConf()
3542
val (actorSystem, _) = AkkaUtils.createActorSystem("Driver",

0 commit comments

Comments
 (0)