You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by sr...@apache.org on 2018/09/30 14:00:27 UTC
spark git commit: [CORE][MINOR] Fix obvious error and compiling for
Scala 2.12.7
Repository: spark
Updated Branches:
refs/heads/master a2f502cf5 -> 40e6ed894
[CORE][MINOR] Fix obvious error and compiling for Scala 2.12.7
## What changes were proposed in this pull request?
Fix an obvious error.
## How was this patch tested?
Existing tests.
Closes #22577 from sadhen/minor_fix.
Authored-by: Darcy Shen <sa...@zoho.com>
Signed-off-by: Sean Owen <se...@databricks.com>
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/40e6ed89
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/40e6ed89
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/40e6ed89
Branch: refs/heads/master
Commit: 40e6ed89405828ff312eca0abd43cfba4b9185b2
Parents: a2f502c
Author: Darcy Shen <sa...@zoho.com>
Authored: Sun Sep 30 09:00:23 2018 -0500
Committer: Sean Owen <se...@databricks.com>
Committed: Sun Sep 30 09:00:23 2018 -0500
----------------------------------------------------------------------
.../org/apache/spark/status/api/v1/OneApplicationResource.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/40e6ed89/core/src/main/scala/org/apache/spark/status/api/v1/OneApplicationResource.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/status/api/v1/OneApplicationResource.scala b/core/src/main/scala/org/apache/spark/status/api/v1/OneApplicationResource.scala
index 32100c5..1f4082c 100644
--- a/core/src/main/scala/org/apache/spark/status/api/v1/OneApplicationResource.scala
+++ b/core/src/main/scala/org/apache/spark/status/api/v1/OneApplicationResource.scala
@@ -175,7 +175,7 @@ private[v1] class OneApplicationAttemptResource extends AbstractApplicationResou
def getAttempt(): ApplicationAttemptInfo = {
uiRoot.getApplicationInfo(appId)
.flatMap { app =>
- app.attempts.filter(_.attemptId == attemptId).headOption
+ app.attempts.find(_.attemptId.contains(attemptId))
}
.getOrElse {
throw new NotFoundException(s"unknown app $appId, attempt $attemptId")
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org