-
Notifications
You must be signed in to change notification settings - Fork 231
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
Log metadata and read data latencies #744
Conversation
/gcbrun |
Codecov Report
@@ Coverage Diff @@
## branch-2.2.x #744 +/- ##
===============================================
Coverage ? 80.29%
Complexity ? 2111
===============================================
Files ? 146
Lines ? 9549
Branches ? 1111
===============================================
Hits ? 7667
Misses ? 1420
Partials ? 462
Flags with carried forward coverage won't be shown. Click here to find out more. Continue to review full report at Codecov.
|
gcsio/src/main/java/com/google/cloud/hadoop/gcsio/GoogleCloudStorageImpl.java
Outdated
Show resolved
Hide resolved
gcsio/src/main/java/com/google/cloud/hadoop/gcsio/GoogleCloudStorageReadChannel.java
Outdated
Show resolved
Hide resolved
gcsio/src/main/java/com/google/cloud/hadoop/gcsio/GoogleCloudStorageImpl.java
Outdated
Show resolved
Hide resolved
gcsio/src/main/java/com/google/cloud/hadoop/gcsio/GoogleCloudStorageReadChannel.java
Outdated
Show resolved
Hide resolved
We should create the PR on |
/gcbrun |
/gcbrun |
gcsio/src/main/java/com/google/cloud/hadoop/gcsio/GoogleCloudStorageImpl.java
Show resolved
Hide resolved
object = | ||
ResilientOperation.retry( | ||
getObject::execute, | ||
readBackOff.get(), | ||
RetryDeterminer.SOCKET_ERRORS, | ||
IOException.class, | ||
sleeper); | ||
|
||
long requestDelay = metadataStopwatch.elapsed(MILLISECONDS); | ||
logger.atFinest().log( |
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.
same here with exceptions
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.
Bump
Thread.currentThread().getId(), | ||
metadataStopwatch.elapsed(MILLISECONDS), | ||
resourceId, | ||
getObject.getLastResponseHeaders().getFirstHeaderStringValue("x-guploader-uploadid")); |
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.
nit: extract string literal to const
Please create the pr against master |
Closing in favor of #749 |
Log metadata and read data latencies on the JSON read path. Moreover when the latency is more than a second, log the request id fetched from the response header