加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 综合聚焦 > 服务器 > 安全 > 正文

scala – 使用带有Spark on Yarn的typesafe配置

发布时间:2020-12-16 09:55:51 所属栏目:安全 来源:网络整理
导读:我有一个Spark作业,从配置文件中读取数据.此文件是类型安全的配置文件. 读取配置的代码如下所示: ConfigFactory.load().getConfig("com.mycompany") 现在我没有将application.conf作为我的超级jar的一部分进行组装,因为我想将该文件作为外部文件传递 我想使
我有一个Spark作业,从配置文件中读取数据.此文件是类型安全的配置文件.

读取配置的代码如下所示:

ConfigFactory.load().getConfig("com.mycompany")

现在我没有将application.conf作为我的超级jar的一部分进行组装,因为我想将该文件作为外部文件传递

我想使用的外部application.conf的内容如下所示:

com.mycompany {
  //configurations my program needs
}

此application.conf文件存在于我的本地计算机文件系统上(而不是HDFS上)

我正在使用Spark 1.6.1和Yarn

这是我的spark-submit命令的样子:

LOG4J_FULL_PATH=/log4j-path
ROOT_DIR=/application.conf-path

    /opt/deploy/spark/bin/spark-submit 
    --class com.mycompany.Main 
    --master yarn 
    --deploy-mode cluster 
    --files $ROOT_DIR/application.conf 
    --files $LOG4J_FULL_PATH/log4j.xml 
    --conf spark.executor.extraClassPath="-Dconfig.file=file:application.conf" 
    --driver-class-path $ROOT_DIR/application.conf 
    --verbose 
    /opt/deploy/lal-ml.jar

我收到的例外是:

2016-11-09 12:32:14 ERROR ApplicationMaster:95 - User class threw exception: com.typesafe.config.ConfigException$Missing: No configuration setting found for key 'com'
com.typesafe.config.ConfigException$Missing: No configuration setting found for key 'com'
    at com.typesafe.config.impl.SimpleConfig.findKey(SimpleConfig.java:124)
    at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:147)
    at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:159)
    at com.typesafe.config.impl.SimpleConfig.find(SimpleConfig.java:164)
    at com.typesafe.config.impl.SimpleConfig.getObject(SimpleConfig.java:218)
    at com.typesafe.config.impl.SimpleConfig.getConfig(SimpleConfig.java:224)
    at com.typesafe.config.impl.SimpleConfig.getConfig(SimpleConfig.java:33)
    at com.mycompany.Main$.main(Main.scala:36)
    at com.mycompany.Main.main(Main.scala)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.apache.spark.deploy.yarn.ApplicationMaster$$anon$2.run(ApplicationMaster.scala:542)

所以我的问题是:有没有人知道如何加载一个外部类型安全的application.conf文件,该文件位于我的本地机器上,带有spark-submit和yarn?

我在How to add a typesafe config file which is located on HDFS to spark-submit (cluster-mode)?和Typesafe Config in Spark以及How to pass -D parameter or environment variable to Spark job?尝试了一些解决方案,但没有任何效果

我会很感激解决这个问题的任何方向

提前致谢

解决方法

因此,通过对Spark 1.6.1源代码的一点挖掘,我找到了解决方案.

这些是您在使用集群模式提交到yarn时使用log4j和application.conf所需的步骤:

>当传递几个文件时,我正在传递application.conf和log4j.xml文件,你需要使用这样的一行提交它们: – files“$ROOT_DIR / application.conf,$LOG4J_FULL_PATH / log4j.xml” (用逗号分隔)
>这是针对application.conf的. application.conf不需要extraJavaOpts(正如我的问题所写).问题是Spark只使用了传递的最后一个–files参数,这就是传递log4j的原因.为了使用log4j.xml,我还必须采取以下步骤
>将另一行添加到spark提交中,如下所示: – conf spark.driver.extraJavaOptions =“ – Dlog4j.configuration = file:log4j.xml” – 请注意,一旦您使用–files传递它,您只需引用该文件名字没有任何路径

注意:我没有尝试过,但是从我看到的,如果你试图在客户端模式下运行它我认为spark.driver.extraJavaOptions行应该重命名为类似driver-java-options的东西
而已.这么简单,我希望这些东西能更好地记录下来.我希望这个答案会对某人有所帮助

干杯

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读