Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/21068#discussion_r185528716
--- Diff:
core/src/main/scala/org/apache/spark/scheduler/BlacklistTracker.scala ---
@@ -273,7 +273,7 @@ private[scheduler] class BlacklistTracker (
* Get the full set of nodes that are blacklisted. Unlike other methods
in this class, this *IS*
* thread-safe -- no lock required on a taskScheduler.
*/
- def nodeBlacklist(): Set[String] = {
+ def nodeBlacklist(): Map[String, Long] = {
--- End diff --
update the comment here and on `TaskSchedulerImpl.nodeBlacklist` to explain
the value.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
