-
Notifications
You must be signed in to change notification settings - Fork 3
/
spark-user-configurable-options.conf
124 lines (113 loc) · 3.14 KB
/
spark-user-configurable-options.conf
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
// Application properties
spark.app.name
spark.driver.cores
spark.driver.maxResultSize
spark.driver.memory
spark.executor.memory
spark.extraListeners
spark.logConf
spark.master
// spark.local.dir
// Runtime Environment
spark.driver.extraClassPath
// spark.driver.extraJavaOptions
spark.driver.extraLibraryPath
spark.driver.userClassPathFirst
spark.executor.extraClassPath
// spark.executor.extraJavaOptions
spark.executor.extraLibraryPath
spark.executor.instances
spark.executor.logs.rolling.maxRetainedFiles
spark.executor.logs.rolling.maxSize
spark.executor.logs.rolling.strategy
spark.executor.logs.rolling.time.interval
spark.executor.userClassPathFirst
// spark.executorEnv.[EnvironmentVariableName]
spark.python.profile
spark.python.profile.dump
spark.python.worker.memory
spark.python.worker.reuse
spark.reducer.maxSizeInFlight
// Shuffle Behavior
spark.shuffle.blockTransferService
spark.shuffle.compress
spark.shuffle.consolidateFiles
spark.shuffle.file.buffer
spark.shuffle.io.maxRetries
spark.shuffle.io.numConnectionsPerPeer
spark.shuffle.io.preferDirectBufs
spark.shuffle.io.retryWait
spark.shuffle.manager
spark.shuffle.memoryFraction
spark.shuffle.service.enabled
spark.shuffle.service.port
spark.shuffle.sort.bypassMergeThreshold
spark.shuffle.spill
spark.shuffle.spill.compress
// Spark UI
spark.eventLog.compress
spark.eventLog.dir
spark.eventLog.enabled
spark.ui.killEnabled
spark.ui.port
spark.ui.retainedJobs
spark.ui.retainedStages
spark.worker.ui.retainedExecutors
spark.worker.ui.retainedDrivers
// Compression and Serialization
spark.broadcast.compress
spark.closure.serializer
spark.io.compression.codec
spark.io.compression.lz4.blockSize
spark.io.compression.snappy.blockSize
spark.kryo.classesToRegister
spark.kryo.referenceTracking
spark.kryo.registrationRequired
spark.kryo.registrator
spark.kryoserializer.buffer.max
spark.kryoserializer.buffer
spark.rdd.compress
spark.serializer
spark.serializer.objectStreamReset
// Execution Behavior
spark.broadcast.blockSize
spark.broadcast.factory
spark.cleaner.ttl
spark.executor.cores
spark.totalExecutor.cores
spark.default.parallelism
spark.executor.heartbeatInterval
spark.files.fetchTimeout
spark.files.useFetchCache
spark.files.overwrite
spark.hadoop.cloneConf
spark.hadoop.validateOutputSpecs
spark.storage.memoryFraction
spark.storage.memoryMapThreshold
spark.storage.unrollFraction
spark.externalBlockStore.blockManager
spark.externalBlockStore.baseDir
spark.externalBlockStore.url
// Networking
// Dynamic Allocation
spark.dynamicAllocation.enabled
spark.dynamicAllocation.executorIdleTimeout
spark.dynamicAllocation.cachedExecutorIdleTimeout
spark.dynamicAllocation.initialExecutors
spark.dynamicAllocation.maxExecutors
spark.dynamicAllocation.minExecutors
spark.dynamicAllocation.schedulerBacklogTimeout
spark.dynamicAllocation.sustainedSchedulerBacklogTimeout
// Security
// Encryption
// Spark Streaming
spark.streaming.backpressure.enabled
spark.streaming.blockInterval
spark.streaming.receiver.maxRate
spark.streaming.receiver.writeAheadLog.enable
spark.streaming.unpersist
spark.streaming.kafka.maxRatePerPartition
spark.streaming.kafka.maxRetries
spark.streaming.ui.retainedBatches
// SparkR
spark.r.numRBackendThreads