Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

Idle Spark Shells

avatar
Explorer

We have some users who start Spark shells and leave them open indefinitely. Without using dynamic resource allocation to deallocate executors - would it be possible to write something to poll YARN to determine if a Spark shell isn't doing anything, and after X time period of inactivity, kill it?

1 ACCEPTED SOLUTION

avatar
Cloudera Employee

FWIW, there is a safety valve setting in CM for spark-defaults.conf

View solution in original post

7 REPLIES 7

avatar
Master Collaborator

Heh, that is a large part of what dynamic allocation was meant for, so you could have a long running process that could only consume resources when it's active. and a shell sitting open is a prime example of that.

 

To some degree you can manage this via resource pools in YARN, and restrict a user, group or perhaps type of usage to a certain set of resources. This would be a pretty crude limit though, just a cap on the problem. Open shells would still keep resources.

 

Timing out shells is tricky because you lose work and state; that's probably pretty surprising.

Really you want dynamic allocation for this.

avatar
Explorer

Thanks for the reply. Being new to CDH, I do have a question. In the general settings of Spark in CM I see there's an option to either turn dynamic allocation off or on. If I wanted to tweak some of the configs for dynamic allocation as listed on the project page (http://spark.apache.org/docs/latest/configuration.html#dynamic-allocation) - would I do so via the Advanced Configuration snippets?

avatar
Master Collaborator
Typically you set this per job on the command line as args to
spark-shell. If a setting is really something to establish as a
default, you can update or point to a new, different
spark-defaults.conf for your jobs. Advanced config snippets are for
services, like the Spark history server, at least to my understanding.
I'm not sure that would apply.

avatar
Explorer

If the problem is users leaving their shells open, I don't think I can trust them to add extra parameters to their CLI arugments to ensure they don't eat up extra resources (from their point of view, why would they care if they're using up my resources?).

 

How about changing the spark-defaults.conf for the Gateway Default Group in CM? Would that accomplish what I'm looking for?

avatar
Master Collaborator
Yes, that sounds right, though I confess I haven't tried that myself.
Others here may have better suggestions.

avatar
Cloudera Employee

FWIW, there is a safety valve setting in CM for spark-defaults.conf

avatar
New Contributor

Can you expand on this? Am pretty new to spark and this is marked as the solution. 

Also, since dynamicAllocation can handle this why would an user not want to enable that instead?