Skip to content

Pipe: Implemented schema batch for meta transfer#17665

Merged
jt2594838 merged 9 commits into
masterfrom
batch
Jun 30, 2026
Merged

Pipe: Implemented schema batch for meta transfer#17665
jt2594838 merged 9 commits into
masterfrom
batch

Fix pipe plan node byte buffer test

bebe100
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Jun 29, 2026 in 2m 11s

Quality Gate failed

Failed conditions
7.2% Duplication on New Code (required ≤ 5%)

See analysis details on SonarQube Cloud

Annotations

Check warning on line 364 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtask.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof IoTDBSink iotdbsink' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7tf94XG0KwB-6342hZ&open=AZ7tf94XG0KwB-6342hZ&pullRequest=17665

Check warning on line 91 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/sync/IoTDBSchemaRegionSink.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof PipeSchemaRegionWritePlanEvent pipeschemaregionwriteplanevent' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7tbvV1bz3NXuDGIrBo&open=AZ7tbvV1bz3NXuDGIrBo&pullRequest=17665

Check warning on line 90 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/airgap/IoTDBSchemaRegionAirGapSink.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof PipeSchemaRegionWritePlanEvent pipeschemaregionwriteplanevent' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7tbvZebz3NXuDGIrBp&open=AZ7tbvZebz3NXuDGIrBp&pullRequest=17665

Check warning on line 352 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/batch/PipeSchemaRegionWritePlanEventBatch.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Method has 9 parameters, which is greater than 7 authorized. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7tbvZobz3NXuDGIrBs&open=AZ7tbvZobz3NXuDGIrBs&pullRequest=17665

Check warning on line 176 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/batch/PipeSchemaRegionWritePlanEventBatch.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Merge the previous cases into this one using comma-separated label. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7tbvZobz3NXuDGIrBr&open=AZ7tbvZobz3NXuDGIrBr&pullRequest=17665

Check warning on line 172 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/payload/evolvable/batch/PipeSchemaRegionWritePlanEventBatch.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Merge the previous cases into this one using comma-separated label. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7tbvZobz3NXuDGIrBq&open=AZ7tbvZobz3NXuDGIrBq&pullRequest=17665

Check warning on line 371 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/sink/PipeSinkSubtask.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof IoTDBSink iotdbsink' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AZ7tf94XG0KwB-6342ha&open=AZ7tf94XG0KwB-6342ha&pullRequest=17665
View more details on SonarQubeCloud