-
Notifications
You must be signed in to change notification settings - Fork 28.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[SPARK-38175][CORE][FOLLOWUP] Remove urlPattern
from HistoryAppStatusStore#replaceLogUrls
method signature
#35567
Conversation
case None => execSummary | ||
} | ||
} | ||
|
||
private def replaceLogUrls(exec: v1.ExecutorSummary, urlPattern: String): v1.ExecutorSummary = { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
SPARK-26311 defines this method with urlPattern
and SPARK-26792 change to use logUrlPattern
held by ExecutorLogUrlHandler
urlPattern
from HistoryAppStatusStore#replaceLogUrls methods signature
urlPattern
from HistoryAppStatusStore#replaceLogUrls methods signatureurlPattern
from HistoryAppStatusStore#replaceLogUrls
method signature
urlPattern
from HistoryAppStatusStore#replaceLogUrls
method signatureurlPattern
from HistoryAppStatusStore#replaceLogUrls
method signature
case None => execList | ||
} | ||
} | ||
|
||
override def executorSummary(executorId: String): v1.ExecutorSummary = { | ||
val execSummary = super.executorSummary(executorId) | ||
logUrlPattern match { | ||
case Some(pattern) => replaceLogUrls(execSummary, pattern) | ||
case Some(_) => replaceLogUrls(execSummary) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is fine though could simplify to a condition on logUrlPattern.nonEmpty or something
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
like 6be9cbf?
@@ -45,20 +45,21 @@ private[spark] class HistoryAppStatusStore( | |||
override def executorList(activeOnly: Boolean): Seq[v1.ExecutorSummary] = { | |||
val execList = super.executorList(activeOnly) | |||
logUrlPattern match { | |||
case Some(pattern) => execList.map(replaceLogUrls(_, pattern)) | |||
case Some(_) => execList.map(replaceLogUrls) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Here too?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Sorry, let me fix this too
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
done
Merged to master |
thanks @srowen |
What changes were proposed in this pull request?
This pr is a followup of SPARK-38175 to remove
urlPattern
fromHistoryAppStatusStore#replaceLogUrls
method signatureWhy are the changes needed?
Cleanup unused symbol.
Does this PR introduce any user-facing change?
No
How was this patch tested?
Pass GA