Caideyipi opened a new pull request, #17946: URL: https://github.com/apache/iotdb/pull/17946
## Description This PR adds an optional Pipe sink config to serialize transfers within the same data region while keeping different data regions independently parallel. - Add connector.serialize-by-region / sink.serialize-by-region, defaulting to true. - When enabled, data region sink subtasks are grouped by region and use one sink subtask per region. - For IoTDBDataRegionAsyncSink, wait for in-flight async handlers before sending the next event in the same region. - Preserve old parallel.tasks behavior when serialize-by-region=false. - Update existing sink parallel ITs to explicitly disable serialize-by-region. ## Tests - git diff --check - mvn -DskipTests spotless:apply -pl iotdb-core/node-commons,iotdb-core/datanode - mvn -DskipTests spotless:apply -pl integration-test -P with-integration-tests - mvn -nsu -pl iotdb-core/node-commons -DskipTests compile Targeted test attempted but blocked before running by existing datanode compile errors in generated/queryengine sources, including missing IFill/IFillFilter, ComparatorChain, parser PERCENTILE, getModeMapSizeThreshold, and DataNodeTableOperatorGenerator#buildAggregator signature mismatch. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
