-
Notifications
You must be signed in to change notification settings - Fork 3.3k
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
HBASE-23210 Backport HBASE-15519 (Add per-user metrics) to branch-1 #755
Conversation
New unit tests pass |
@joshelser I couldn't ask @ankitsinghal for a review for some reason, but i see you recently reviewed similar |
b770177
to
b31f442
Compare
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.
Two minor things, but LGTM.
class SweepRunnable implements Runnable { | ||
@Override public void run() { | ||
if (LOG.isTraceEnabled()) { | ||
LOG.trace("Starting sweep of lossyCounting-" + name); |
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, could use the {}
markers and drop the isTraceEnabled()
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.
This came in from branch-2 change. I agree but try not to second guess the original contributor on backports.
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.
Two minor things, but LGTM.
try { | ||
sweep(); | ||
} catch (Exception exception) { | ||
LOG.debug("Error while sweeping of lossyCounting-{}", name, exception); |
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.
(damnit, lost the previous comment)
Make sure you're getting the right debug
method here. The debug(String, Object, Exception)
not debug(String, Object, Object)
. Hit this the other day.
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.
Fixing
b31f442
to
ba2d5ff
Compare
💔 -1 overall
This message was automatically generated. |
Back soon to fix checkstyle issues |
ba2d5ff
to
dc96c24
Compare
Fixed some checkstyle nits, will merge tomorrow |
💔 -1 overall
This message was automatically generated. |
💔 -1 overall
This message was automatically generated. |
HBASE-15519 Add per-user metrics with lossy counting Introducing property hbase.regionserver.user.metrics.enabled(Default:true) to disable user metrics in case it accounts for any performance issues
dc96c24
to
5127c2e
Compare
Fixed the other checkstyle indent nit |
this.bucketSize = (long) Math.ceil(1 / errorRate); | ||
this.currentTerm = 1; | ||
this.totalDataCount = 0; | ||
this.data = new ConcurrentHashMap<>(); | ||
this.listener = listener; | ||
calculateCurrentTerm(); | ||
executor = Executors.newSingleThreadExecutor(); |
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 think this causes the RegionServer process to hang upon shutdown since we're not using daemon threads.
HBASE-15519 Add per-user metrics with lossy counting
Introducing property hbase.regionserver.user.metrics.enabled(Default:true)
to disable user metrics in case it accounts for any performance issues