This is an automated email from the ASF dual-hosted git repository.
irashid pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 8313015 [SPARK-28005][YARN] Remove unnecessary log from
SparkRackResolver
8313015 is described below
commit 8313015e8dd11aafc5b887773e467892d15134de
Author: Gabor Somogyi <[email protected]>
AuthorDate: Wed Jun 26 09:50:54 2019 -0500
[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 #24935 from gaborgsomogyi/SPARK-28005.
Authored-by: Gabor Somogyi <[email protected]>
Signed-off-by: Imran Rashid <[email protected]>
---
.../main/scala/org/apache/spark/deploy/yarn/SparkRackResolver.scala | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/SparkRackResolver.scala
b/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/SparkRackResolver.scala
index cab3272..51be932 100644
---
a/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/SparkRackResolver.scala
+++
b/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/SparkRackResolver.scala
@@ -67,6 +67,9 @@ private[spark] class SparkRackResolver(conf: Configuration)
extends Logging {
}
private def coreResolve(hostNames: Seq[String]): Seq[Node] = {
+ if (hostNames.isEmpty) {
+ return Seq.empty
+ }
val nodes = new ArrayBuffer[Node]
// dnsToSwitchMapping is thread-safe
val rNameList = dnsToSwitchMapping.resolve(hostNames.toList.asJava).asScala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
