Hi all:

    In my application, I start SparkContext sc and execute some task on sc.
(Each task is a thread, which execute some transform and action on RDDs)
    For each task, I use "sc.setJobGroup(JOB_GROUPID, JOB_DESCRIPTION)" to
set jobGroup for each task.
    But when I call "sc.cancelJobGroup(JOB_GROUPID)" to try to cancel the
task, it doesn't work.
    I want to know it's my usage mistake, or there exist some bugs?

Thanks

Reply via email to