enhancementgood first issue
Repository metrics
- Stars
- (7 stars)
- PR merge metrics
- (PR metrics pending)
Description
This could be added to DEFAULT_IMPORTS:
private val sc = SparkContext.getOrCreate()
private val pysparkMemory = sc.getConf.get("spark.executor.pyspark.memory")
import resource
limit = {pysparkMemoryBytes}
resource.setrlimit(resource.RLIMIT_AS, (limit, limit))