(shardingsphere) branch master updated: Recover rate limit in InventoryDumper (#37630)

[zhonghongsheng]

This is an automated email from the ASF dual-hosted git repository.

zhonghongsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 69f0d93dc2a Recover rate limit in InventoryDumper (#37630)
69f0d93dc2a is described below

commit 69f0d93dc2a3f667b5efe1fae3d65db8e99dc07d
Author: Hongsheng Zhong <zhonghongsh...@apache.org>
AuthorDate: Sun Jan 4 09:57:41 2026 +0800

    Recover rate limit in InventoryDumper (#37630)
---
 .../data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java   | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
 
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
index 7f8d3361b2e..e102552d6b8 100644
--- 
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
+++ 
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
@@ -128,8 +128,12 @@ public final class InventoryDumper extends 
AbstractPipelineLifecycleRunnable imp
         RecordTableInventoryDumpCalculator dumpCalculator = new 
RecordTableInventoryDumpCalculator(dumperContext.getBatchSize(), 
StreamingRangeType.SMALL);
         long rowCount = 0L;
         try {
+            JobRateLimitAlgorithm rateLimitAlgorithm = 
dumperContext.getRateLimitAlgorithm();
             String firstUniqueKey = 
calculateParam.getFirstUniqueKey().getName();
             for (List<DataRecord> each : 
dumpCalculator.calculate(calculateParam)) {
+                if (null != rateLimitAlgorithm) {
+                    
rateLimitAlgorithm.intercept(PipelineSQLOperationType.SELECT, 1);
+                }
                 channel.push(Collections.unmodifiableList(each));
                 IngestPosition position = 
UniqueKeyIngestPosition.newInstance(Range.closed(dumpCalculator.getFirstUniqueKeyValue(each.get(each.size()
 - 1), firstUniqueKey), range.getUpperBound()));
                 dumperContext.getCommonContext().setPosition(position);