Skip to content

Commit cbac60d

Browse files
Fabio BusoAckuq
authored andcommitted
Reduce number of event logs flushes (apache#26)
1 parent 5c92607 commit cbac60d

1 file changed

Lines changed: 23 additions & 23 deletions

File tree

core/src/main/scala/org/apache/spark/scheduler/EventLoggingListener.scala

Lines changed: 23 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -155,96 +155,96 @@ private[spark] class EventLoggingListener(
155155
}
156156

157157
// log stage completed event
158-
logEvent(event, flushLogger = true)
158+
logEvent(event)
159159
}
160160

161161
override def onJobStart(event: SparkListenerJobStart): Unit = {
162-
logEvent(event.copy(properties = redactProperties(event.properties)), flushLogger = true)
162+
logEvent(event.copy(properties = redactProperties(event.properties)))
163163
}
164164

165165
override def onJobEnd(event: SparkListenerJobEnd): Unit = logEvent(event, flushLogger = true)
166166

167167
override def onBlockManagerAdded(event: SparkListenerBlockManagerAdded): Unit = {
168-
logEvent(event, flushLogger = true)
168+
logEvent(event)
169169
}
170170

171171
override def onBlockManagerRemoved(event: SparkListenerBlockManagerRemoved): Unit = {
172-
logEvent(event, flushLogger = true)
172+
logEvent(event)
173173
}
174174

175175
override def onUnpersistRDD(event: SparkListenerUnpersistRDD): Unit = {
176-
logEvent(event, flushLogger = true)
176+
logEvent(event)
177177
}
178178

179179
override def onApplicationStart(event: SparkListenerApplicationStart): Unit = {
180-
logEvent(event, flushLogger = true)
180+
logEvent(event)
181181
}
182182

183183
override def onApplicationEnd(event: SparkListenerApplicationEnd): Unit = {
184184
logEvent(event, flushLogger = true)
185185
}
186186
override def onExecutorAdded(event: SparkListenerExecutorAdded): Unit = {
187-
logEvent(event, flushLogger = true)
187+
logEvent(event)
188188
}
189189

190190
override def onExecutorRemoved(event: SparkListenerExecutorRemoved): Unit = {
191-
logEvent(event, flushLogger = true)
191+
logEvent(event)
192192
}
193193

194194
override def onExecutorBlacklisted(event: SparkListenerExecutorBlacklisted): Unit = {
195-
logEvent(event, flushLogger = true)
195+
logEvent(event)
196196
}
197197

198198
override def onExecutorExcluded(event: SparkListenerExecutorExcluded): Unit = {
199-
logEvent(event, flushLogger = true)
199+
logEvent(event)
200200
}
201201

202202
override def onExecutorBlacklistedForStage(
203203
event: SparkListenerExecutorBlacklistedForStage): Unit = {
204-
logEvent(event, flushLogger = true)
204+
logEvent(event)
205205
}
206206

207207
override def onExecutorExcludedForStage(
208208
event: SparkListenerExecutorExcludedForStage): Unit = {
209-
logEvent(event, flushLogger = true)
209+
logEvent(event)
210210
}
211211

212212
override def onNodeBlacklistedForStage(event: SparkListenerNodeBlacklistedForStage): Unit = {
213-
logEvent(event, flushLogger = true)
213+
logEvent(event)
214214
}
215215

216216
override def onNodeExcludedForStage(event: SparkListenerNodeExcludedForStage): Unit = {
217-
logEvent(event, flushLogger = true)
217+
logEvent(event)
218218
}
219219

220220
override def onExecutorUnblacklisted(event: SparkListenerExecutorUnblacklisted): Unit = {
221-
logEvent(event, flushLogger = true)
221+
logEvent(event)
222222
}
223223

224224
override def onExecutorUnexcluded(event: SparkListenerExecutorUnexcluded): Unit = {
225-
logEvent(event, flushLogger = true)
225+
logEvent(event)
226226
}
227227

228228

229229
override def onNodeBlacklisted(event: SparkListenerNodeBlacklisted): Unit = {
230-
logEvent(event, flushLogger = true)
230+
logEvent(event)
231231
}
232232

233233
override def onNodeExcluded(event: SparkListenerNodeExcluded): Unit = {
234-
logEvent(event, flushLogger = true)
234+
logEvent(event)
235235
}
236236

237237
override def onNodeUnblacklisted(event: SparkListenerNodeUnblacklisted): Unit = {
238-
logEvent(event, flushLogger = true)
238+
logEvent(event)
239239
}
240240

241241
override def onNodeUnexcluded(event: SparkListenerNodeUnexcluded): Unit = {
242-
logEvent(event, flushLogger = true)
242+
logEvent(event)
243243
}
244244

245245
override def onBlockUpdated(event: SparkListenerBlockUpdated): Unit = {
246246
if (shouldLogBlockUpdates) {
247-
logEvent(event, flushLogger = true)
247+
logEvent(event)
248248
}
249249
}
250250

@@ -269,12 +269,12 @@ private[spark] class EventLoggingListener(
269269
}
270270

271271
override def onResourceProfileAdded(event: SparkListenerResourceProfileAdded): Unit = {
272-
logEvent(event, flushLogger = true)
272+
logEvent(event)
273273
}
274274

275275
override def onOtherEvent(event: SparkListenerEvent): Unit = {
276276
if (event.logEvent) {
277-
logEvent(event, flushLogger = true)
277+
logEvent(event)
278278
}
279279
}
280280

0 commit comments

Comments
 (0)