-
Notifications
You must be signed in to change notification settings - Fork 9.1k
HADOOP-17065. Add Network Counters to ABFS #2056
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
Conversation
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.
overall patch looks great!
some minor tuning of statistic names/descriptions and the tests, and it will be good to go
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AbfsStatistic.java
Outdated
Show resolved
Hide resolved
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AbfsStatistic.java
Outdated
Show resolved
Hide resolved
GET_RESPONSE("get_response", | ||
"Total number of times response was recorded after sending requests."), | ||
BYTES_SEND("bytes_send", | ||
"Total bytes sent through http requests."), |
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.
how about "bytes sent from Azure Datalake"
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.
wouldn't it be "bytes sent to Azure Datalake"?
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.
yes. Or just "bytes uploaded". avoids having to deal with any future rebranding
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AbfsStatistic.java
Outdated
Show resolved
Hide resolved
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AbfsStatistic.java
Outdated
Show resolved
Hide resolved
hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AbfsStatistic.java
Outdated
Show resolved
Hide resolved
...tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystemStore.java
Outdated
Show resolved
Hide resolved
...ols/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/ITestAbfsNetworkStatistics.java
Outdated
Show resolved
Hide resolved
🎊 +1 overall
This message was automatically generated. |
...ols/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/ITestAbfsNetworkStatistics.java
Outdated
Show resolved
Hide resolved
} else { | ||
this.client = new AbfsClient(baseUrl, creds, abfsConfiguration, | ||
new ExponentialRetryPolicy(abfsConfiguration.getMaxIoRetries()), | ||
sasTokenProvider, abfsPerfTracker); | ||
sasTokenProvider, abfsPerfTracker, instrumentation); |
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.
At this point the variable name is instrumentation and then it AbfsClient() it is statistics. I know these classes has been created earlier but I feel the names are bit confusing.
A few suggestions.
- AbfsCounters could be AbfsInstrumentation and AbfsInstrumentation could be AbfsInstrumentationImpl
- Let AbfsCounters be same. change AbfsInstrumentation to AbfsCountersImpl.
It is not important to change but if everybody feels the same then sooner the better.
CC @steveloughran
LGTM. Great patch @mehakmeet |
🎊 +1 overall
This message was automatically generated. |
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.
lgtm. we just need to agree on the name of the bytes sent counter
I have added "Azure Datalake" to most of these network counters. I agree with the future rebranding issue, and I think I should make them more generalized. |
🎊 +1 overall
This message was automatically generated. |
@steveloughran I am not able to understand the -0 patch error. I made a new branch locally and checked if there were any conflicts after rebasing and there weren't any. |
cut an accidentally pasted test name and add "a" in some of the descriptions
Contributed by Mehakmeet Singh.
Contributed by Mehakmeet Singh.
Contributed by Mehakmeet Singh. (cherry picked from commit 3472c3e)
Contributed by Mehakmeet Singh. (cherry picked from commit 3472c3e)
Contributed by Mehakmeet Singh. Conflicts: hadoop-tools/hadoop-azure/src/main/java/org/apache/hadoop/fs/azurebfs/AzureBlobFileSystemStore.java Change-Id: I3fbfc5bbef00e39dbca4fbea69638d0e78b3cfb5
Contributed by: Mehakmeet Singh
Tested by: mvn -T 1C -Dparallel-tests=abfs clean verify
Region: East US, West US