Skip to content

Commit

Permalink
fixup
Browse files Browse the repository at this point in the history
  • Loading branch information
zhztheplayer committed Aug 29, 2024
1 parent 44c2d94 commit d3a6013
Showing 1 changed file with 5 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -40,13 +40,14 @@ abstract class AffinityManager extends LogLevelUtil with Logging {

private val softAffinityAllocation = new SoftAffinityStrategy

val minOnTargetHosts: Int
lazy val minOnTargetHosts: Int = GlutenConfig.GLUTEN_SOFT_AFFINITY_MIN_TARGET_HOSTS_DEFAULT_VALUE

val usingSoftAffinity: Boolean
lazy val usingSoftAffinity: Boolean = true

val detectDuplicateReading: Boolean
lazy val detectDuplicateReading: Boolean = true

val duplicateReadingMaxCacheItems: Int
lazy val duplicateReadingMaxCacheItems: Int =
GlutenConfig.GLUTEN_SOFT_AFFINITY_DUPLICATE_READING_MAX_CACHE_ITEMS_DEFAULT_VALUE

// (execId, host) list
val fixedIdForExecutors = new mutable.ListBuffer[Option[(String, String)]]()
Expand Down

0 comments on commit d3a6013

Please sign in to comment.