Github user ajbozarth commented on a diff in the pull request:
https://github.com/apache/spark/pull/19750#discussion_r151288247
--- Diff:
core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala ---
@@ -315,48 +315,43 @@ private[history] class FsHistoryProvider(conf:
SparkConf, clock: Clock)
(new InMemoryStore(), true)
}
- val listener = if (needReplay) {
- val _listener = new AppStatusListener(kvstore, conf, false,
+ if (needReplay) {
+ val replayBus = new ReplayListenerBus()
--- End diff --
It's still there in this PR though (line 297)
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
