Skip to content

Commit 8313015

Browse files
gaborgsomogyisquito
authored andcommitted
[SPARK-28005][YARN] Remove unnecessary log from SparkRackResolver
## What changes were proposed in this pull request? SparkRackResolver generates an INFO message every time is called with 0 arguments. In this PR I've deleted it because it's too verbose. ## How was this patch tested? Existing unit tests + spark-shell. Closes apache#24935 from gaborgsomogyi/SPARK-28005. Authored-by: Gabor Somogyi <[email protected]> Signed-off-by: Imran Rashid <[email protected]>
1 parent d83f84a commit 8313015

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/SparkRackResolver.scala

+3
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,9 @@ private[spark] class SparkRackResolver(conf: Configuration) extends Logging {
6767
}
6868

6969
private def coreResolve(hostNames: Seq[String]): Seq[Node] = {
70+
if (hostNames.isEmpty) {
71+
return Seq.empty
72+
}
7073
val nodes = new ArrayBuffer[Node]
7174
// dnsToSwitchMapping is thread-safe
7275
val rNameList = dnsToSwitchMapping.resolve(hostNames.toList.asJava).asScala

0 commit comments

Comments
 (0)