Spark Application Garbage Collector

ContextCleaneris a Spark service that is responsible for application-wide cleanuparrow-up-right of shufflesarrow-up-right , RDDsarrow-up-right , broadcastsarrow-up-right , accumulatorsarrow-up-right and checkpointed RDDsarrow-up-right that is aimed at reducing the memory requirements of long-running data-heavy Spark applications.

ContextCleaner runs on the driver. It is created and immediately started when SparkContext startsarrow-up-right (and spark.cleaner.referenceTracking Spark propertyarrow-up-right is enabled, which it is by default). It is stopped when SparkContext is stoppedarrow-up-right

.

Last updated