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
[SW-727] Improve method for downloading H2O logs #587
Conversation
// Skip nodes that aren't healthy, since they are likely to cause the entire process to hang. | ||
try { | ||
if (node.isHealthy) { | ||
val g = new GetLogsFromNode |
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.
interesting i would expect new GetLogsFromNode(i).doIt().bytes()
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.
Me too, but current H2O API does not allow that and I wanted to limit the scope of this change just to SW
private def zipLogs(results: Array[Array[Byte]], clientResult: Array[Byte], topDir: String, destination: URI): URI = { | ||
assert(H2O.CLOUD._memary.length == results.length, "Unexpected change in the cloud!") | ||
val l = results.map(_.length).sum | ||
|
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.
Minor: 2 empty lines
destination | ||
} | ||
|
||
/** Zip the H2O logs and return them as byte array */ |
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.
Wrong comment, we return the path to the downloaded logs
thanks @mmalohlava ! |
ef97953
to
2edfe7f
Compare
(cherry picked from commit d46f3d9)
(cherry picked from commit d46f3d9)
(cherry picked from commit d46f3d9)
No description provided.