diff options
author | Sandy Ryza <sandy@cloudera.com> | 2014-08-28 16:18:50 -0700 |
---|---|---|
committer | Andrew Or <andrewor14@gmail.com> | 2014-08-28 16:19:01 -0700 |
commit | f4cbf5e3d55d8ae66bfb1dde80cef81a2dfad7e4 (patch) | |
tree | 530e2cdfd1a6b60ea2777a4f319fbf5aa0856501 /yarn/alpha | |
parent | 0b9718add107aa7cc9528fea177ae8239158014b (diff) | |
download | spark-f4cbf5e3d55d8ae66bfb1dde80cef81a2dfad7e4.tar.gz spark-f4cbf5e3d55d8ae66bfb1dde80cef81a2dfad7e4.tar.bz2 spark-f4cbf5e3d55d8ae66bfb1dde80cef81a2dfad7e4.zip |
SPARK-3082. yarn.Client.logClusterResourceDetails throws NPE if requeste...
...d queue doesn't exist
Author: Sandy Ryza <sandy@cloudera.com>
Closes #1984 from sryza/sandy-spark-3082 and squashes the following commits:
fe08c37 [Sandy Ryza] Remove log message entirely
85253ad [Sandy Ryza] SPARK-3082. yarn.Client.logClusterResourceDetails throws NPE if requested queue doesn't exist
(cherry picked from commit 92af2314f27e80227174499f2fca505bd551cda7)
Signed-off-by: Andrew Or <andrewor14@gmail.com>
Diffstat (limited to 'yarn/alpha')
-rw-r--r-- | yarn/alpha/src/main/scala/org/apache/spark/deploy/yarn/Client.scala | 11 |
1 files changed, 1 insertions, 10 deletions
diff --git a/yarn/alpha/src/main/scala/org/apache/spark/deploy/yarn/Client.scala b/yarn/alpha/src/main/scala/org/apache/spark/deploy/yarn/Client.scala index 82f79d88a3..9be78546c1 100644 --- a/yarn/alpha/src/main/scala/org/apache/spark/deploy/yarn/Client.scala +++ b/yarn/alpha/src/main/scala/org/apache/spark/deploy/yarn/Client.scala @@ -89,17 +89,8 @@ class Client(clientArgs: ClientArguments, hadoopConf: Configuration, spConf: Spa def logClusterResourceDetails() { val clusterMetrics: YarnClusterMetrics = super.getYarnClusterMetrics - logInfo("Got Cluster metric info from ASM, numNodeManagers = " + + logInfo("Got cluster metric info from ASM, numNodeManagers = " + clusterMetrics.getNumNodeManagers) - - val queueInfo: QueueInfo = super.getQueueInfo(args.amQueue) - logInfo( """Queue info ... queueName = %s, queueCurrentCapacity = %s, queueMaxCapacity = %s, - queueApplicationCount = %s, queueChildQueueCount = %s""".format( - queueInfo.getQueueName, - queueInfo.getCurrentCapacity, - queueInfo.getMaximumCapacity, - queueInfo.getApplications.size, - queueInfo.getChildQueues.size)) } |