From 66b7bea7f82efa4f52186d15824d31035be253de Mon Sep 17 00:00:00 2001
From: azuryyu <azuryyyu@gmail.com>
Date: Tue, 24 Dec 2013 18:16:49 +0800
Subject: [PATCH] Make App report interval configurable during 'run on Yarn'
---
.../src/main/scala/org/apache/spark/deploy/yarn/Client.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
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" +
--
GitLab