-
Notifications
You must be signed in to change notification settings - Fork 455
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 iteration to result count in BulkImport code #5312
Conversation
I am still looking into things to see if...
Input on either of these would be helpful. |
while (true) { | ||
iterationCount++; | ||
|
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.
I believe this code is ok, it jump around in the metadata table and does not scan over tablets it does not need to.
The code that does scan over unrelated tablets in the metadata table is here . Would be good to track counts of skipped vs total tablets in that code. The function is called multiple times for a single bulk load and could get the counts from all calls and log after that loop that calls the function.
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.
Good catch. I moved the log message to the spot you mentioned.
I added a check so things are only logged if there are "wasted iterations". With that check in place I can't get the message to be logged.
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.
I added a check so things are only logged if there are "wasted iterations". With that check in place I can't get the message to be logged.
Which test are you running? The code seems ok, but it would be good to see the log message.
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.
I was running BulkNewIT
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.
Created #5345 without seeing these changes.
I think your changes are better as these directly show the time wasted skipping.
server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/LoadFiles.java
Outdated
Show resolved
Hide resolved
server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/LoadFiles.java
Show resolved
Hide resolved
The updating logging as of 03de2e4 looks like this:
I added the changes in commit 2ebdd00 and ran BulkNewIT to get the log above |
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.
I like the new changes.
Related to #5201. Logs the number of iterations performed to produce the resulting returned value (overlapping tablets). This will make it more evident if this code is doing a lot of scanning relative to the number of values we are looking for.