Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/20203#discussion_r161884194
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/TaskSetBlacklist.scala ---
@@ -36,7 +36,9 @@ import org.apache.spark.util.Clock
* [[TaskSetManager]] this class is designed only to be called from code
with a lock on the
* TaskScheduler (e.g. its event handlers). It should not be called from
other threads.
*/
-private[scheduler] class TaskSetBlacklist(val conf: SparkConf, val
stageId: Int, val clock: Clock)
+private[scheduler] class TaskSetBlacklist(private val listenerBus:
LiveListenerBus,
+ val conf: SparkConf, val
stageId: Int,
--- End diff --
style: if its multiline, each param on its own line, double-indented
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
