incubator-livy
incubator-livy copied to clipboard
[LIVY-336] Livy should not spawn one thread per job to track the job on Yarn
- Moved YARN related code from
SparkYarnApp
to a new classYarnInterface
- Removed "yarnAppMinotorThreads" that are created for each Spark application
- Created one thread that polls YARN to get
ApplicationId
s and - Created a pool of threads that gets
ApplicationAttempts
andContainerReports
from YARN- because there is no API to get
ApplicationAttempts
andContainerReports
in bulk - the thread pool is actually used by Scala
Future
s
- because there is no API to get
- Updated test cases in
SparkYarnAppSpec
to match the new design
Task-Url: https://issues.cloudera.org/browse/LIVY-336
@meisam this PR looks old and inactive. May you please close it? Thanks.
IIRC there was a huge discussion on the mailing list about this... this would be a good feature to have if it's brought up to date.
Sure! I'll update it. Is the IIRC channel public? If yes, can you point me to it?
IIRC = if I remember correctly.
I would love for this to actually get in. We are having problems right now with Livy thread starvation if more than 20 jobs are running at the same time.
Hi @meisam , Now we need this part. If there are no updates, I will continue your work in the new PR and keep your previous commits.