LuciferYang commented on code in PR #44229: URL: https://github.com/apache/spark/pull/44229#discussion_r1418462913
########## core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala: ########## @@ -96,12 +96,13 @@ private[deploy] class Worker( private val HEARTBEAT_MILLIS = conf.get(WORKER_TIMEOUT) * 1000 / 4 // Model retries to connect to the master, after Hadoop's model. - // The first six attempts to reconnect are in shorter intervals (between 5 and 15 seconds) - // Afterwards, the next 10 attempts are between 30 and 90 seconds. + // The first WORKER_INITIAL_REGISTRATION_RETRIES attempts to reconnect are in shorter intervals + // (between 5 and 15 seconds). Afterwards, the next attempts are between 30 and 90 seconds while + // The total number of retries are less than or equal to WORKER_MAX_REGISTRATION_RETRIES. // A bit of randomness is introduced so that not all of the workers attempt to reconnect at // the same time. - private val INITIAL_REGISTRATION_RETRIES = 6 - private val TOTAL_REGISTRATION_RETRIES = INITIAL_REGISTRATION_RETRIES + 10 + private val INITIAL_REGISTRATION_RETRIES = conf.get(WORKER_INITIAL_REGISTRATION_RETRIES) + private val TOTAL_REGISTRATION_RETRIES = conf.get(WORKER_MAX_REGISTRATION_RETRIES) Review Comment: So, is there a need for a log to clarify this result? Because in the above configuration scenario, init follows the configuration value of maximum rather than its own configuration value. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org
