EMR上运行spark程序出现内存分配报错

发布于 2022-09-04 21:40:32 字数 2197 浏览 16 评论 0

spark小白求指教:
最近在做相关的作业,spark的程序弄成jar包,上传到EMR上跑之后,程序运行8秒就失败了,报错信息:


17/05/06 13:44:12 INFO client.RMProxy: Connecting to ResourceManager at ip-172-31-30-132.us-west-2.compute.internal/172.31.30.132:8032
17/05/06 13:44:13 INFO yarn.Client: Requesting a new application from cluster with 2 NodeManagers
17/05/06 13:44:13 INFO yarn.Client: Verifying our application has not requested more than the maximum memory capability of the cluster (1024 MB per container)
Exception in thread "main" java.lang.IllegalArgumentException: Required executor memory (1024+384 MB) is above the max threshold (1024 MB) of this cluster! Please check the values of 'yarn.scheduler.maximum-allocation-mb' and/or 'yarn.nodemanager.resource.memory-mb'.

at org.apache.spark.deploy.yarn.Client.verifyClusterResources(Client.scala:283)
at org.apache.spark.deploy.yarn.Client.submitApplication(Client.scala:139)
at org.apache.spark.deploy.yarn.Client.run(Client.scala:1016)
at org.apache.spark.deploy.yarn.Client$.main(Client.scala:1076)
at org.apache.spark.deploy.yarn.Client.main(Client.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:731)
at org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:181)
at org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:206)
at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:121)
at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)

Command exiting with ret '1'


EMR的指标是:
2个core c1 medium instances, 1个master c1 medium instance
JAR 位置: command-runner.jar
主类: 无
自变量: spark-submit --deploy-mode cluster --class target/guo-0.0.1-SNAPSHOT.jar s3://finalprojectprogram/guo-0.0.1-SNAPSHOT.jar s3://projectdata-amazonproductrate/relative_small_data.txt s3://finalprojectoutputfile/mimic30
出现故障时的操作: 继续

非常感谢!

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(2

一口甜 2022-09-11 21:40:32

看起来是资源分配的时候内存爆了

乞讨 2022-09-11 21:40:32

用 EMR 的 Spark 相比自己搭 Spark,除了节省时间和资源管控方便,还有什么优势?

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文