diff options
| author | Sandy Ryza <sandy@cloudera.com> | 2014-09-12 16:48:28 -0500 |
|---|---|---|
| committer | Thomas Graves <tgraves@apache.org> | 2014-09-12 16:48:28 -0500 |
| commit | 1d767967e925f1d727957c2d43383ef6ad2c5d5e (patch) | |
| tree | 1e8f6e0a7f655bc52d5399fd7985bd289a9ad0c2 /yarn | |
| parent | 15a564598fe63003652b1e24527c432080b5976c (diff) | |
| download | spark-1d767967e925f1d727957c2d43383ef6ad2c5d5e.tar.gz spark-1d767967e925f1d727957c2d43383ef6ad2c5d5e.tar.bz2 spark-1d767967e925f1d727957c2d43383ef6ad2c5d5e.zip | |
SPARK-3014. Log a more informative messages in a couple failure scenario...
...s
Author: Sandy Ryza <sandy@cloudera.com>
Closes #1934 from sryza/sandy-spark-3014 and squashes the following commits:
ae19cc1 [Sandy Ryza] SPARK-3014. Log a more informative messages in a couple failure scenarios
Diffstat (limited to 'yarn')
| -rw-r--r-- | yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala b/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala index 878b6db546..735d7723b0 100644 --- a/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala +++ b/yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala @@ -283,11 +283,9 @@ private[spark] class ApplicationMaster(args: ApplicationMasterArguments, } val sparkContext = sparkContextRef.get() - assert(sparkContext != null || count >= numTries) if (sparkContext == null) { - logError( - "Unable to retrieve sparkContext inspite of waiting for %d, numTries = %d".format( - count * waitTime, numTries)) + logError(("SparkContext did not initialize after waiting for %d ms. Please check earlier" + + " log output for errors. Failing the application.").format(numTries * waitTime)) } sparkContext } |