Repository: spark
Updated Branches:
refs/heads/master 321b4f03b -> 1f81dda37
[SPARK-20354][CORE][REST-API] When I request access to the 'http:
//ip:port/api/v1/applications' link, return 'sparkUser' is empty in REST API.
## What changes were proposed in this pull request?
When I request access to the 'http: //ip:port/api/v1/applications' link, get
the json. I need the 'sparkUser' field specific value, because my Spark big
data management platform needs to filter through this field which user submits
the application to facilitate my administration and query, but the current
return of the json string is empty, causing me this Function can not be
achieved, that is, I do not know who the specific application is submitted by
this REST Api.
**current return json:**
[ {
"id" : "app-20170417152053-0000",
"name" : "KafkaWordCount",
"attempts" : [ {
"startTime" : "2017-04-17T07:20:51.395GMT",
"endTime" : "1969-12-31T23:59:59.999GMT",
"lastUpdated" : "2017-04-17T07:20:51.395GMT",
"duration" : 0,
**"sparkUser" : "",**
"completed" : false,
"endTimeEpoch" : -1,
"startTimeEpoch" : 1492413651395,
"lastUpdatedEpoch" : 1492413651395
} ]
} ]
**When I fix this question, return json:**
[ {
"id" : "app-20170417154201-0000",
"name" : "KafkaWordCount",
"attempts" : [ {
"startTime" : "2017-04-17T07:41:57.335GMT",
"endTime" : "1969-12-31T23:59:59.999GMT",
"lastUpdated" : "2017-04-17T07:41:57.335GMT",
"duration" : 0,
**"sparkUser" : "mr",**
"completed" : false,
"startTimeEpoch" : 1492414917335,
"endTimeEpoch" : -1,
"lastUpdatedEpoch" : 1492414917335
} ]
} ]
## How was this patch tested?
manual tests
Please review http://spark.apache.org/contributing.html before opening a pull
request.
Author: éå°é¾ 10207633 <[email protected]>
Author: guoxiaolong <[email protected]>
Author: guoxiaolongzte <[email protected]>
Closes #17656 from guoxiaolongzte/SPARK-20354.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/1f81dda3
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/1f81dda3
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/1f81dda3
Branch: refs/heads/master
Commit: 1f81dda37cfc2049fabd6abd93ef3720d0aa03ea
Parents: 321b4f0
Author: éå°é¾ 10207633 <[email protected]>
Authored: Tue Apr 18 10:02:21 2017 -0700
Committer: Marcelo Vanzin <[email protected]>
Committed: Tue Apr 18 10:02:21 2017 -0700
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/ui/SparkUI.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/1f81dda3/core/src/main/scala/org/apache/spark/ui/SparkUI.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/ui/SparkUI.scala
b/core/src/main/scala/org/apache/spark/ui/SparkUI.scala
index 7d31ac5..bf4cf79 100644
--- a/core/src/main/scala/org/apache/spark/ui/SparkUI.scala
+++ b/core/src/main/scala/org/apache/spark/ui/SparkUI.scala
@@ -117,7 +117,7 @@ private[spark] class SparkUI private (
endTime = new Date(-1),
duration = 0,
lastUpdated = new Date(startTime),
- sparkUser = "",
+ sparkUser = getSparkUser,
completed = false
))
))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
