Skip to content

Commit 48d4901

Browse files
committed
update compaction read operation rate
1 parent 3e6ce63 commit 48d4901

File tree

1 file changed

+1
-0
lines changed
  • iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils

1 file changed

+1
-0
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/CompactionUtils.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -628,6 +628,7 @@ private static void acquireCompactionReadRate(long size) {
628628
if (size <= 0) {
629629
return;
630630
}
631+
CompactionTaskManager.getInstance().getCompactionReadOperationRateLimiter().acquire(1);
631632
RateLimiter rateLimiter = CompactionTaskManager.getInstance().getCompactionReadRateLimiter();
632633
while (size >= Integer.MAX_VALUE) {
633634
size -= Integer.MAX_VALUE;

0 commit comments

Comments
 (0)