[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biju Nair updated HBASE-19924: -- Labels: quota throttle (was: ) > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 0.16.0, 1.2.6 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Labels: quota, throttle > Fix For: 1.3.3, 2.0.0, 1.4.5, 1.2.7 > > Attachments: HBASE-19924-branch-1-v001.patch, > HBASE-19924-master-v001.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Purtell updated HBASE-19924: --- Fix Version/s: (was: 1.5.0) > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 0.16.0, 1.2.6 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Fix For: 1.3.3, 2.0.0, 1.4.5, 1.2.7 > > Attachments: HBASE-19924-branch-1-v001.patch, > HBASE-19924-master-v001.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Purtell updated HBASE-19924: --- Fix Version/s: 1.4.5 1.3.3 1.2.7 I think this is a bug so I picked it back to the release branches 1.2 and up. Please let me know or revert if you disagree. > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 0.16.0, 1.2.6 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Fix For: 1.5.0, 1.2.7, 1.3.3, 2.0.0, 1.4.5 > > Attachments: HBASE-19924-branch-1-v001.patch, > HBASE-19924-master-v001.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huaxiang sun updated HBASE-19924: - Resolution: Fixed Fix Version/s: 1.5.0 Status: Resolved (was: Patch Available) pushed the patch to branch-1. > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 0.16.0, 1.2.6 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Fix For: 1.5.0, 2.0.0 > > Attachments: HBASE-19924-branch-1-v001.patch, > HBASE-19924-master-v001.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huaxiang sun updated HBASE-19924: - Attachment: HBASE-19924-branch-1-v001.patch > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 0.16.0, 1.2.6 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Fix For: 2.0.0 > > Attachments: HBASE-19924-branch-1-v001.patch, > HBASE-19924-master-v001.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huaxiang sun updated HBASE-19924: - Status: Patch Available (was: Reopened) > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 1.2.6, 0.16.0 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Fix For: 2.0.0 > > Attachments: HBASE-19924-branch-1-v001.patch, > HBASE-19924-master-v001.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huaxiang sun updated HBASE-19924: - Resolution: Fixed Fix Version/s: 2.0.0 Status: Resolved (was: Patch Available) Pushed the patch to 2.0.0+, thanks for reviews! > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 0.16.0, 1.2.6 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Fix For: 2.0.0 > > Attachments: HBASE-19924-master-v001.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huaxiang sun updated HBASE-19924: - Attachment: HBASE-19924-master-v002.patch > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 0.16.0, 1.2.6 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Attachments: HBASE-19924-master-v001.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] stack updated HBASE-19924: -- Attachment: HBASE-19924-master-v002.patch > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 0.16.0, 1.2.6 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Attachments: HBASE-19924-master-v001.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch, > HBASE-19924-master-v002.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huaxiang sun updated HBASE-19924: - Attachment: HBASE-19924-master-v002.patch > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 0.16.0, 1.2.6 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Attachments: HBASE-19924-master-v001.patch, > HBASE-19924-master-v002.patch, HBASE-19924-master-v002.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huaxiang sun updated HBASE-19924: - Attachment: HBASE-19924-master-v002.patch > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 0.16.0, 1.2.6 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Attachments: HBASE-19924-master-v001.patch, > HBASE-19924-master-v002.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huaxiang sun updated HBASE-19924: - Status: Patch Available (was: Open) > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 1.2.6, 2.0 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Attachments: HBASE-19924-master-v001.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Updated] (HBASE-19924) hbase rpc throttling does not work for multi() with request count rater.
[ https://issues.apache.org/jira/browse/HBASE-19924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huaxiang sun updated HBASE-19924: - Attachment: HBASE-19924-master-v001.patch > hbase rpc throttling does not work for multi() with request count rater. > > > Key: HBASE-19924 > URL: https://issues.apache.org/jira/browse/HBASE-19924 > Project: HBase > Issue Type: Bug > Components: rpc >Affects Versions: 1.2.6, 2.0 >Reporter: huaxiang sun >Assignee: huaxiang sun >Priority: Major > Attachments: HBASE-19924-master-v001.patch > > > Basically, rpc throttling does not work for request count based rater for > multi. for the following code, when it calls limiter's checkQuota(), > numWrites/numReads is lost. > {code:java} > @Override > public void checkQuota(int numWrites, int numReads, int numScans) throws > ThrottlingException { > writeConsumed = estimateConsume(OperationType.MUTATE, numWrites, 100); > readConsumed = estimateConsume(OperationType.GET, numReads, 100); > readConsumed += estimateConsume(OperationType.SCAN, numScans, 1000); > writeAvailable = Long.MAX_VALUE; > readAvailable = Long.MAX_VALUE; > for (final QuotaLimiter limiter : limiters) { > if (limiter.isBypass()) continue; > limiter.checkQuota(writeConsumed, readConsumed); > readAvailable = Math.min(readAvailable, limiter.getReadAvailable()); > writeAvailable = Math.min(writeAvailable, limiter.getWriteAvailable()); > } > for (final QuotaLimiter limiter : limiters) { > limiter.grabQuota(writeConsumed, readConsumed); > } > }{code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)