|
|
|
SPARK-42357
|
SPARK-41550
Log `exitCode` when `SparkContext.stop` starts
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-42343
|
SPARK-41550
Ignore `IOException` in `handleBlockRemovalFailure` if SparkContext is stopped
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-42190
|
SPARK-41550
Support `local[*]` in `spark-submit` in K8s environment
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-41543
|
SPARK-41550
Add `TOTAL_SHUFFLE_WRITE` executor roll policy
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-41540
|
SPARK-41550
Add `DISK_USED` executor roll policy
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-41536
|
SPARK-41550
Remove `Dynamic Resource Allocation` from K8s Future Work
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40979
|
SPARK-41550
Keep removed executor info in decommission state
|
Zhongwei Zhu
|
Zhongwei Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40636
|
SPARK-41550
Fix wrong remained shuffles log in BlockManagerDecommissioner
|
Zhongwei Zhu
|
Zhongwei Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40596
|
SPARK-41550
Populate ExecutorDecommission with more informative messages
|
Bo Zhang
|
Bo Zhang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40481
|
SPARK-41550
Ignore stage fetch failure caused by decommissioned executor
|
Zhongwei Zhu
|
Zhongwei Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40379
|
SPARK-41550
Propagate decommission executor loss reason during onDisconnect in K8s
|
Holden Karau
|
Holden Karau
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40304
|
SPARK-41550
Add decomTestTag to K8s Integration Test
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40269
|
SPARK-41550
Randomize the orders of peer in BlockManagerDecommissioner
|
Zhongwei Zhu
|
Zhongwei Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40198
|
SPARK-41550
Enable spark.storage.decommission.(rdd|shuffle)Blocks.enabled by default
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-40060
|
SPARK-41550
Add numberDecommissioningExecutors metric
|
Zhongwei Zhu
|
Zhongwei Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-39987
|
SPARK-41550
Support PEAK_JVM_(ON|OFF)HEAP_MEMORY executor rolling policy
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-39846
|
SPARK-41550
Enable spark.dynamicAllocation.shuffleTracking.enabled by default
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-39450
|
SPARK-41550
Reuse PVCs by default
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-39324
|
SPARK-41550
Log ExecutorDecommission as INFO level in TaskSchedulerImpl
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-39322
|
SPARK-41550
Remove `Experimental` from `spark.dynamicAllocation.shuffleTracking.enabled`
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-38418
|
SPARK-41550
Add PySpark cleanShuffleDependencies API
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-38417
|
SPARK-41550
Remove `Experimental` from `RDD.cleanShuffleDependencies` API
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-38062
|
SPARK-41550
FallbackStorage shouldn't attempt to resolve arbitrary "remote" hostname
|
Erik Krogen
|
Erik Krogen
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-38023
|
SPARK-41550
ExecutorMonitor.onExecutorRemoved should handle ExecutorDecommission as finished
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-38019
|
SPARK-41550
ExecutorMonitor.timedOutExecutors should be deterministic
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-33870
|
SPARK-41550
Enable spark.storage.replication.proactive by default
|
Dongjoon Hyun
|
Dongjoon Hyun
|
|
Resolved |
Fixed
|
|
|
|
|