Skip to content

Throttle async pipe sink on receiver reject#17928

Merged
jt2594838 merged 2 commits into
masterfrom
fix-pipe-receiver-backpressure
Jun 17, 2026
Merged

Throttle async pipe sink on receiver reject#17928
jt2594838 merged 2 commits into
masterfrom
fix-pipe-receiver-backpressure

Handle review

79c41c5
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis succeeded Jun 16, 2026 in 2m 39s

Quality Gate passed

Issues
1 New issue
0 Accepted issues

Measures
0 Security Hotspots
0.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube Cloud

Annotations

Check warning on line 141 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/async/handler/PipeTransferTsFileHandler.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

A "Brain Method" was detected. Refactor it to reduce at least one of the following metrics: LOC from 94 to 64, Complexity from 16 to 14, Nesting Level from 3 to 2, Number of Variables from 14 to 6. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7ONz5PahZCUm-Ezdh9&open=AZ7ONz5PahZCUm-Ezdh9&pullRequest=17928
View more details on SonarQubeCloud