We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 40a8fef commit 05ba6daCopy full SHA for 05ba6da
core/src/main/scala/org/apache/spark/deploy/master/Master.scala
@@ -72,9 +72,7 @@ private[spark] class Master(
72
val waitingApps = new ArrayBuffer[ApplicationInfo]
73
val completedApps = new ArrayBuffer[ApplicationInfo]
74
var nextAppNumber = 0
75
-
76
val appIdToUI = new HashMap[String, SparkUI]
77
- val fileSystemsUsed = new HashSet[FileSystem]
78
79
val drivers = new HashSet[DriverInfo]
80
val completedDrivers = new ArrayBuffer[DriverInfo]
@@ -159,7 +157,6 @@ private[spark] class Master(
159
157
recoveryCompletionTask.cancel()
160
158
}
161
webUi.stop()
162
- fileSystemsUsed.foreach(_.close())
163
masterMetricsSystem.stop()
164
applicationMetricsSystem.stop()
165
persistenceEngine.close()
0 commit comments