Description
Currently we use the foreach RDD action to submit a spark job. In order to implement job monitoring functionality (HIVE-7438), we need to get a job identifier when submitting the job, so that we can later register some listener for that specific job.
This task requires facilitation from spark side (SPARK-2636). I've tried to use AsyncRDDActions instead of the traditional actions, and it proved to be a possible way to get the job ID we need.
Attachments
Issue Links
- depends upon
-
SPARK-2636 Expose job ID in JobWaiter API
- Resolved
- is part of
-
HIVE-7438 Counters, statistics, and metrics [Spark Branch]
- Resolved
-
HIVE-7292 Hive on Spark
- Resolved
- is related to
-
HIVE-7439 Spark job monitoring and error reporting [Spark Branch]
- Resolved