diff options
| author | azuryyu <azuryyyu@gmail.com> | 2013-12-24 18:16:49 +0800 |
|---|---|---|
| committer | azuryyu <azuryyyu@gmail.com> | 2013-12-24 18:16:49 +0800 |
| commit | 66b7bea7f82efa4f52186d15824d31035be253de (patch) | |
| tree | a783c1238cc60a5bb0605d9c9e3d1bca6da1439d /new-yarn/src/main/scala/org/apache | |
| parent | a8bb86389d8dc8efeff83561aea044a3c4924df5 (diff) | |
| download | spark-66b7bea7f82efa4f52186d15824d31035be253de.tar.gz spark-66b7bea7f82efa4f52186d15824d31035be253de.tar.bz2 spark-66b7bea7f82efa4f52186d15824d31035be253de.zip | |
Make App report interval configurable during 'run on Yarn'
Diffstat (limited to 'new-yarn/src/main/scala/org/apache')
| -rw-r--r-- | new-yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala b/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala index 94678815e8..9fdee29498 100644 --- a/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala +++ b/new-yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala @@ -437,8 +437,10 @@ class Client(conf: Configuration, args: ClientArguments) extends YarnClientImpl } def monitorApplication(appId: ApplicationId): Boolean = { + val interval = System.getProperty("spark.yarn.report.interval", "1000").toLong + while (true) { - Thread.sleep(1000) + Thread.sleep(interval) val report = super.getApplicationReport(appId) logInfo("Application report from ASM: \n" + |