pyspark.SparkContext.clearJobTags

SparkContext.clearJobTags() → None

Clear the current thread’s job tags.

New in version 3.5.0.

See also

SparkContext.addJobTag()

SparkContext.removeJobTag()

SparkContext.getJobTags()

SparkContext.cancelJobsWithTag()

SparkContext.setInterruptOnCancel()

Examples

>>> sc.addJobTag("job_to_cancel")
>>> sc.clearJobTags()
>>> sc.getJobTags()
set()

previous

pyspark.SparkContext.cancelJobsWithTag

next

pyspark.SparkContext.defaultMinPartitions