-
Notifications
You must be signed in to change notification settings - Fork 858
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
changed asynch call to future/blocking #352
Conversation
…talMemoryBytesSpilled metric) (linkedin#310)
…equires stages/failedTasks Rest API) (linkedin#288)
…eakJvmUsedMemory metric) (linkedin#318)
…kUnifiedMemory metric) (linkedin#281)
…Custom SHS - Requires peakJvmUsedMemory metric) (linkedin#287)
Separated out Driver checks into a separate Driver Metrics heuristic: Checks driver configurations, driver GC time and JVM used memory.
@@ -94,38 +92,41 @@ class SparkFetcher(fetcherConfigurationData: FetcherConfigurationData) | |||
Success(data) | |||
}, | |||
e => { | |||
logger.error(s"Failed fetching data for ${appId}", e) | |||
logger.error(s"Failed fetching data for ${appId}") |
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.
As discussed, retain the exception message and turn this into a warning message.
@@ -16,11 +16,9 @@ | |||
|
|||
package com.linkedin.drelephant.spark.fetchers | |||
|
|||
import scala.async.Async |
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.
Can you update the description of this PR with the motivation behind this change?
a49a0f8
to
7dfe640
Compare
f333c3f
to
3436b55
Compare
No description provided.