Ask a Question
Ask Question Login
Corporate Training
  1. Community
  2. Python
  3. Question
Python

What is spark.driver.maxResultSize?

Asked by Dylan Perez Apr 23, 2021 1.5K views 1 answer
Share

About this question

What does this attribute do exactly? I mean at first (since I am not battling with a job that fails due to out-of-memory errors) I thought I should increase that.


On second thought, it seems that this attribute defines the max size of the result a worker can send to the driver, so leaving it at the default (1G) would be the best approach to protect the driver.


But will happen in this case, the worker will have to send more messages, so the overhead will be just that the job will be slower?


If I understand correctly, assuming that a worker wants to send 4G of data to the driver, then having spark.driver.maxResultSize=1G, will cause the worker to send 4 messages (instead of 1 with unlimited spark.driver.maxResultSize). If so, then increasing that attribute to protect my driver from being assassinated by Yarn should be wrong.

But still, the question above remains. I mean what if I set it to 1M (the minimum), will it be the most protective approach?

Your answer

1 Answer

More Python discussions

Learn & Explore

Free tutorials and interview questions from industry experts — learn the skill, then get ready to prove it.

Latest Python Blogs

Guides, tips and career advice on Python from JanBask experts.