| commit | f9152062cf3126d6aa45062e19a7cb2fd96aeb58 | [log] [tgz] |
|---|---|---|
| author | Murtadha Hubail <murtadha.hubail@couchbase.com> | Tue Feb 15 00:15:08 2022 +0300 |
| committer | Murtadha Hubail <mhubail@apache.org> | Tue Feb 15 21:06:54 2022 +0000 |
| tree | d659ad9453d12064066c9d5a16faade8bfb89777 | |
| parent | 2099f8009596796a9b067480129d9dddf4860ed5 [diff] |
[NO ISSUE][STO] Fix write rate limiter calculation - user model changes: no - storage format changes: no - interface changes: no Details: - Fix the write request size to the write rate limiter by considering the page size. Change-Id: If875755d65476339b90adcf6e654e32e97655f3d Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/15286 Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Tested-by: Murtadha Hubail <mhubail@apache.org> Reviewed-by: Murtadha Hubail <mhubail@apache.org> Reviewed-by: Ali Alsuliman <ali.al.solaiman@gmail.com>
diff --git a/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/impls/LSMIndexPageWriteCallback.java b/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/impls/LSMIndexPageWriteCallback.java index 0ad7033..85a2d39 100644 --- a/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/impls/LSMIndexPageWriteCallback.java +++ b/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/impls/LSMIndexPageWriteCallback.java
@@ -43,7 +43,7 @@ } public void beforeWrite(ICachedPage page) throws HyracksDataException { - rateLimiter.request(page.getFrameSizeMultiplier()); + rateLimiter.request(page.getPageSize() * page.getFrameSizeMultiplier()); } @Override