aboutsummaryrefslogtreecommitdiff
path: root/yarn
diff options
context:
space:
mode:
authorhushan[胡珊] <hushan@xiaomi.com>2015-06-16 20:48:33 +0100
committerSean Owen <sowen@cloudera.com>2015-06-16 20:48:33 +0100
commit29c5025a7058e64baccb6dfe3ad74d918da64494 (patch)
tree2dca06b68b88af347c8e3e801ea9fedc5ef60a87 /yarn
parent658814c898bec04c31a8e57f8da0103497aac6ec (diff)
downloadspark-29c5025a7058e64baccb6dfe3ad74d918da64494.tar.gz
spark-29c5025a7058e64baccb6dfe3ad74d918da64494.tar.bz2
spark-29c5025a7058e64baccb6dfe3ad74d918da64494.zip
[SPARK-8387] [WEBUI] Only show 4096 bytes content for executor log instead of show all
Author: hushan[胡珊] <hushan@xiaomi.com> Closes #6834 from suyanNone/small-display and squashes the following commits: 744212f [hushan[胡珊]] Only show 4096 bytes content for executor log instead all
Diffstat (limited to 'yarn')
-rw-r--r--yarn/src/main/scala/org/apache/spark/deploy/yarn/ExecutorRunnable.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ExecutorRunnable.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/ExecutorRunnable.scala
index 9d04d241da..b0937083bc 100644
--- a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ExecutorRunnable.scala
+++ b/yarn/src/main/scala/org/apache/spark/deploy/yarn/ExecutorRunnable.scala
@@ -303,8 +303,8 @@ class ExecutorRunnable(
val address = container.getNodeHttpAddress
val baseUrl = s"$httpScheme$address/node/containerlogs/$containerId/$user"
- env("SPARK_LOG_URL_STDERR") = s"$baseUrl/stderr?start=0"
- env("SPARK_LOG_URL_STDOUT") = s"$baseUrl/stdout?start=0"
+ env("SPARK_LOG_URL_STDERR") = s"$baseUrl/stderr?start=-4096"
+ env("SPARK_LOG_URL_STDOUT") = s"$baseUrl/stdout?start=-4096"
}
System.getenv().filterKeys(_.startsWith("SPARK")).foreach { case (k, v) => env(k) = v }