pyspark连接条件期间内存问题

q5lcpyga  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(432)

我正在使用spark 2.1.0。我有2个Dataframe不超过3 mb。当我尝试在两个Dataframe上运行内部连接时,我的所有转换逻辑都能完美地工作。但是当我在两个Dataframe上使用rightouter连接时,我得到了下面的错误。
错误

RN for exceeding memory limits. 1.5 GB of 1.5 GB physical memory used. 
Consider boosting spark.yarn.executor.memoryOverhead.
17/08/02 02:29:53 ERROR cluster.YarnScheduler: Lost executor 337 on ip-172-
21-1-105.eu-west-1.compute.internal: Container killed by YARN for exceeding 
memory limits. 1.5 GB of 1.5 GB physical memory used. Consider boosting 
spark.yarn.executor.memoryOverhead.
17/08/02 02:29:53 WARN scheduler.TaskSetManager: Lost task 34.0 in stage 
283.0 (TID 11396, ip-172-21-1-105.eu-west-1.compute.internal, executor 337): 
ExecutorLostFailure (executor 337 exited caused by one of the running tasks) 
Reason: Container killed by YARN for exceeding memory limits. 1.5 GB of 1.5 
GB physical memory used. Consider boosting 
spark.yarn.executor.memoryOverhead.
17/08/02 02:29:53 WARN server.TransportChannelHandler: Exception in 
connection from /172.21.1.105:50342
java.io.IOException: Connection reset by peer

我尝试了备选方案1)df.coalesce(xvalue).show()2)尝试设置执行器内存,但没有效果。
这一问题在过去几周一直悬而未决。谁能告诉我哪里出了问题吗

ajsxfq5m

ajsxfq5m1#

你能分享一下关于数据集的细节吗。
两个数据集中的行和列数。
你试过leftouterjoin吗,它也会给你同样的错误。
当做,
尼拉吉

相关问题