188

是的……已经讨论了很多。

但是,存在很多歧义,并且提供了一些答案……包括在 jars/executor/driver 配置或选项中复制 JAR 引用。

模棱两可和/或遗漏的细节

应为每个选项澄清以下歧义、不清楚和/或遗漏的细节:

  • ClassPath 如何受到影响
    • 司机
    • 执行器(用于正在运行的任务)
    • 两个都
    • 一点也不
  • 分隔符:逗号、冒号、分号
  • 如果提供的文件是自动分发的
    • 对于任务(对每个执行者)
    • 对于远程驱动程序(如果在集群模式下运行)
  • 接受的 URI 类型:本地文件、HDFS、HTTP 等。
  • 如果复制一个公共位置,该位置在哪里(HDFS,本地?)

它影响的选项:

  1. --jars
  2. SparkContext.addJar(...)方法
  3. SparkContext.addFile(...)方法
  4. --conf spark.driver.extraClassPath=...或者--driver-class-path ...
  5. --conf spark.driver.extraLibraryPath=..., 或者--driver-library-path ...
  6. --conf spark.executor.extraClassPath=...
  7. --conf spark.executor.extraLibraryPath=...
  8. 不要忘记,spark-submit 的最后一个参数也是一个 .jar 文件。

我知道在哪里可以找到主要的 Apache Spark 文档,特别是关于如何提交、可用选项以及JavaDoc的信息。然而,这给我留下了相当多的漏洞,尽管它也得到了部分答案。

我希望它不是那么复杂,并且有人可以给我一个清晰简洁的答案。

如果我从文档中猜测,似乎--jars, 和SparkContext addJaraddFile方法是自动分发文件的方法,而其他选项仅修改 ClassPath。

假设为简单起见,我可以同时使用三个主要选项添加其他应用程序 JAR 文件是否安全?

spark-submit --jar additional1.jar,additional2.jar \
  --driver-library-path additional1.jar:additional2.jar \
  --conf spark.executor.extraLibraryPath=additional1.jar:additional2.jar \
  --class MyClass main-application.jar

我在另一个帖子的答案中找到了一篇不错的文章。然而,并没有学到什么新东西。海报确实对本地驱动程序(yarn-client)和远程驱动程序(yarn-cluster)之间的区别做了很好的评论。牢记这一点绝对很重要。

4

6 回答 6

215

类路径:

ClassPath 会受到影响,具体取决于您提供的内容。有几种方法可以在类路径上设置一些东西:

  • spark.driver.extraClassPath--driver-class-path或者它是在运行驱动程序的节点上设置额外类路径的别名。
  • spark.executor.extraClassPath在 Worker 节点上设置额外的类路径。

如果您希望某个 JAR 同时作用于 Master 和 Worker,则必须在 BOTH 标志中分别指定它们。

分隔符:

遵循与 JVM 相同的规则

  • Linux:冒号,:
    • 例如:--conf "spark.driver.extraClassPath=/opt/prog/hadoop-aws-2.7.1.jar:/opt/prog/aws-java-sdk-1.10.50.jar"
  • Windows:分号,;
    • 例如:--conf "spark.driver.extraClassPath=/opt/prog/hadoop-aws-2.7.1.jar;/opt/prog/aws-java-sdk-1.10.50.jar"

文件分发:

这取决于您运行作业的模式:

  1. 客户端模式 - Spark 启动Netty HTTP 服务器,该服务器在启动时为每个工作节点分发文件。当您开始 Spark 作业时,您可以看到:

    16/05/08 17:29:12 INFO HttpFileServer: HTTP File server directory is /tmp/spark-48911afa-db63-4ffc-a298-015e8b96bc55/httpd-84ae312b-5863-4f4c-a1ea-537bfca2bc2b
    16/05/08 17:29:12 INFO HttpServer: Starting HTTP Server
    16/05/08 17:29:12 INFO Utils: Successfully started service 'HTTP file server' on port 58922.
    16/05/08 17:29:12 INFO SparkContext: Added JAR /opt/foo.jar at http://***:58922/jars/com.mycode.jar with timestamp 1462728552732
    16/05/08 17:29:12 INFO SparkContext: Added JAR /opt/aws-java-sdk-1.10.50.jar at http://***:58922/jars/aws-java-sdk-1.10.50.jar with timestamp 1462728552767
    
  2. 集群模式 - 在集群模式下,Spark 选择了一个领导Worker节点来执行Driver进程。这意味着作业不是直接从节点运行的。在这里,Spark不会设置 HTTP 服务器。您必须通过 HDFS、S3 或其他可用于所有节点的源手动使您的 JAR 文件可用于所有工作节点。

接受的文件 URI

“提交应用程序”中,Spark 文档很好地解释了文件可接受的前缀:

使用 spark-submit 时,应用程序 jar 以及 --jars 选项中包含的任何 jar 将自动传输到集群。Spark 使用以下 URL 方案来允许传播 jar 的不同策略:

  • file: - 绝对路径和 file:/ URI 由驱动程序的 HTTP 文件服务器提供服务,每个执行程序都从驱动程序 HTTP 服务器提取文件。
  • hdfs:, http:, https:, ftp: - 这些从 URI 中按预期下拉文件和 JAR
  • local: - 以 local:/ 开头的 URI 应作为本地文件存在于每个工作节点上。这意味着不会产生网络 IO,并且适用于推送给每个工作人员或通过 NFS、GlusterFS 等共享的大型文件/JAR。

请注意,JAR 和文件将复制到执行程序节点上每个 SparkContext 的工作目录。

如前所述,JAR 文件被复制到每个Worker节点的工作目录中。那具体在哪里?它通常在 下,你会看到它们是这样的:/var/run/spark/work

drwxr-xr-x    3 spark spark   4096 May 15 06:16 app-20160515061614-0027
drwxr-xr-x    3 spark spark   4096 May 15 07:04 app-20160515070442-0028
drwxr-xr-x    3 spark spark   4096 May 15 07:18 app-20160515071819-0029
drwxr-xr-x    3 spark spark   4096 May 15 07:38 app-20160515073852-0030
drwxr-xr-x    3 spark spark   4096 May 15 08:13 app-20160515081350-0031
drwxr-xr-x    3 spark spark   4096 May 18 17:20 app-20160518172020-0032
drwxr-xr-x    3 spark spark   4096 May 18 17:20 app-20160518172045-0033

当您查看内部时,您会看到您部署的所有 JAR 文件:

[*@*]$ cd /var/run/spark/work/app-20160508173423-0014/1/
[*@*]$ ll
total 89988
-rwxr-xr-x 1 spark spark   801117 May  8 17:34 awscala_2.10-0.5.5.jar
-rwxr-xr-x 1 spark spark 29558264 May  8 17:34 aws-java-sdk-1.10.50.jar
-rwxr-xr-x 1 spark spark 59466931 May  8 17:34 com.mycode.code.jar
-rwxr-xr-x 1 spark spark  2308517 May  8 17:34 guava-19.0.jar
-rw-r--r-- 1 spark spark      457 May  8 17:34 stderr
-rw-r--r-- 1 spark spark        0 May  8 17:34 stdout

受影响的选项:

最重要的是要了解优先级。如果您通过代码传递任何属性,它将优先于您通过 指定的任何选项spark-submit。Spark 文档中提到了这一点:

任何指定为标志或属性文件中的值都将传递给应用程序并与通过 SparkConf 指定的值合并。直接在 SparkConf 上设置的属性具有最高优先级,然后是传递给 spark-submit 或 spark-shell 的标志,然后是 spark-defaults.conf 文件中的选项

因此,请确保将这些值设置在适当的位置,这样当一个优先于另一个时,您就不会感到惊讶。

让我们分析问题中的每个选项:

  • --jarsvs SparkContext.addJar:这些是相同的。只有一个是通过 Spark 提交设置的,一个是通过代码设置的。选择一个更适合你的。需要注意的重要一点是,使用这些选项中的任何一个都不会将 JAR 文件添加到您的驱动程序/执行程序类路径中。您需要使用extraClassPath两者的配置显式添加它们。
  • SparkContext.addJarvs :当您有需要与代码一起使用的依赖SparkContext.addFile项时,请使用前者。当您只想将任意文件传递给工作节点时使用后者,这不是代码中的运行时依赖项。
  • --conf spark.driver.extraClassPath=...or --driver-class-path:这些是别名,你选择哪一个都没有关系
  • --conf spark.driver.extraLibraryPath=..., or --driver-library-path ...同上,别名。
  • --conf spark.executor.extraClassPath=...:当您有一个无法包含在 über JAR 中的依赖项(例如,因为库版本之间存在编译时冲突)并且需要在运行时加载时,请使用此选项。
  • --conf spark.executor.extraLibraryPath=...java.library.path这是作为JVM的选项传递的。当您需要对 JVM 可见的库路径时使用此选项。

可以安全地假设为简单起见,我可以同时使用 3 个主要选项添加其他应用程序 jar 文件:

您可以放心地假设这仅适用于客户端模式,而不适用于集群模式。正如我之前所说。此外,您给出的示例有一些多余的论点。例如,将 JAR 文件传递​​给--driver-library-path是没有用的。extraClassPath如果您希望它们在您的类路径中,则需要将它们传递给。最终,当您在驱动程序和工作程序上部署外部 JAR 文件时,您需要:

spark-submit --jars additional1.jar,additional2.jar \
  --driver-class-path additional1.jar:additional2.jar \
  --conf spark.executor.extraClassPath=additional1.jar:additional2.jar \
  --class MyClass main-application.jar
于 2016-05-20T13:40:21.863 回答
6

Apache Spark 2.1.0 中的另一种方法是--conf spark.driver.userClassPathFirst=true在 spark-submit 期间使用,这会改变依赖加载的优先级,从而改变 spark-job 的行为,方法是优先考虑用户添加到类路径的 JAR 文件与--jars选项。

于 2017-04-03T19:01:54.927 回答
3

使用--jars: 如果你想为jar/xml文件的位置指定一个目录,它不允许目录扩展。这意味着如果您需要为每个 JAR 文件指定绝对路径。

如果您指定--driver-class-path并在纱线集群模式下执行,则驱动程序类不会更新。我们可以在 Tab 环境下的 Spark UI 或 Spark 历史服务器下验证类路径是否更新。

对我有用的选项是传递包含目录扩展并在纱线集群模式下工作的 JAR 文件--conf。最好将驱动程序和执行程序类路径传递为--conf,这会将它们添加到 Spark 会话对象本身,并且这些路径会反映在 Spark 配置中。但确保将 JAR 文件放在集群中的同一路径上。

spark-submit \
  --master yarn \
  --queue spark_queue \
  --deploy-mode cluster    \
  --num-executors 12 \
  --executor-memory 4g \
  --driver-memory 8g \
  --executor-cores 4 \
  --conf spark.ui.enabled=False \
  --conf spark.driver.extraClassPath=/usr/hdp/current/hbase-master/lib/hbase-server.jar:/usr/hdp/current/hbase-master/lib/hbase-common.jar:/usr/hdp/current/hbase-master/lib/hbase-client.jar:/usr/hdp/current/hbase-master/lib/zookeeper.jar:/usr/hdp/current/hbase-master/lib/hbase-protocol.jar:/usr/hdp/current/spark2-thriftserver/examples/jars/scopt_2.11-3.3.0.jar:/usr/hdp/current/spark2-thriftserver/examples/jars/spark-examples_2.10-1.1.0.jar:/etc/hbase/conf \
  --conf spark.hadoop.mapred.output.dir=/tmp \
  --conf spark.executor.extraClassPath=/usr/hdp/current/hbase-master/lib/hbase-server.jar:/usr/hdp/current/hbase-master/lib/hbase-common.jar:/usr/hdp/current/hbase-master/lib/hbase-client.jar:/usr/hdp/current/hbase-master/lib/zookeeper.jar:/usr/hdp/current/hbase-master/lib/hbase-protocol.jar:/usr/hdp/current/spark2-thriftserver/examples/jars/scopt_2.11-3.3.0.jar:/usr/hdp/current/spark2-thriftserver/examples/jars/spark-examples_2.10-1.1.0.jar:/etc/hbase/conf \
  --conf spark.hadoop.mapreduce.output.fileoutputformat.outputdir=/tmp
于 2018-01-01T05:14:47.157 回答
3

在部署模式的情况下,与 JAR 文件和类路径相关的其他可配置 Spark 选项yarn如下。

从 Spark 文档中,

spark.yarn.jars

包含要分发到 YARN 容器的 Spark 代码的库列表。默认情况下,YARN 上的 Spark 将使用本地安装的 Spark jar,但 Spark jar 也可以位于 HDFS 上的世界可读位置。这允许 YARN 将其缓存在节点上,这样就不需要在每次应用程序运行时分发它。例如,要指向 HDFS 上的 jar,将此配置设置为 hdfs:///some/path。允许使用 Glob。

spark.yarn.archive

包含分发到 YARN 缓存所需的 Spark jar 的存档。如果设置,此配置将替换 spark.yarn.jars,并且归档文件用于所有应用程序的容器中。存档应在其根目录中包含 jar 文件。与前一个选项一样,存档也可以托管在 HDFS 上以加快文件分发。

用户可以配置此参数来指定他们的 JAR 文件,这些文件又包含在 Spark 驱动程序的类路径中。

于 2019-05-18T05:44:07.957 回答
2

将 spark-submit 与 --master yarn-cluster 一起使用时,应用程序 JAR 文件以及--jars选项中包含的任何 JAR 文件将自动传输到集群。--jars之后提供的 URL必须用逗号分隔。该列表包含在驱动程序和执行程序类路径中

例子:

spark-submit --master yarn-cluster --jars ../lib/misc.jar, ../lib/test.jar --class MainClass MainApp.jar

参考

提交申请

于 2020-06-04T21:21:05.960 回答
0

当我们使用 spark-submit 实用程序提交 Apache Spark 作业时,有一个选项,--jars. 使用此选项,我们可以将 JAR 文件传递​​给 Spark 应用程序。

于 2019-05-07T10:54:30.400 回答