Skip to content

Implement UDP transport for air-gap sink - #17954

Merged
jt2594838 merged 14 commits into
masterfrom
air-gap-udp-transport
Oct 30, 2026
Merged

Implement UDP transport for air-gap sink#17954
jt2594838 merged 14 commits into
masterfrom
air-gap-udp-transport

Address air-gap UDP review comments

39dcb47
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Oct 29, 2026 in 6m 49s

Quality Gate failed

Failed conditions
E Reliability Rating on New Code (required ≥ A)
C Security Rating on New Code (required ≥ A)

See analysis details on SonarQube Cloud

Catch issues before they fail your Quality Gate with our IDE extension SonarQube for IDE

Annotations

Check warning on line 2408 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof AddViewColumnProcedure addviewcolumnprocedure' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGH6R-SwgglOi2hjc-L&open=AaGH6R-SwgglOi2hjc-L&pullRequest=17954

Check warning on line 196 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Catch Exception instead of Error. 

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

Check warning on line 2210 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof AggregationNode aggregation' 

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

Check warning on line 250 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'method call' child has incorrect indentation level 10, expected level should be 14. 

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

Check warning on line 1620 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Expected @throws tag for 'MetadataException'. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGH6R3ewgglOi2hjc-A&open=AaGH6R3ewgglOi2hjc-A&pullRequest=17954

Check warning on line 107 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/subscription/DropSubscriptionProcedure.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Reduce the total number of break and continue statements in this loop to use at most one. 

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

Check warning on line 1740 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/schema/ClusterSchemaManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Complete the task associated to this TODO comment. 

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

Check warning on line 50 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALFormatProvider.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'}' at column 54 should be alone on a line. 

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

Check warning on line 550 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/ConsensusSubscriptionBroker.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this "Collections.sort()" with "List.sort()". 

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

Check warning on line 589 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/memory/MemoryPool.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

"future" is a method parameter, and should not be used for synchronization. 

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

Check warning on line 275 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/utils/WALFileUtils.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove the "new long[]" prefix; the declaration already specifies the array type. 

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

Check warning on line 273 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/utils/WALFileUtils.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove the "new long[]" prefix; the declaration already specifies the array type. 

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

Check warning on line 216 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionSetupHandler.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Reduce the total number of break and continue statements in this loop to use at most one. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGH6QV-wgglOi2hjc9a&open=AaGH6QV-wgglOi2hjc9a&pullRequest=17954

Check warning on line 169 in iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/AnyChildBlocked.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof Exception exception' 

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

Check warning on line 543 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/AutoCreateSchemaExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Invert this negated condition and swap the two branches of the ternary. 

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

Check warning on line 369 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/TreeDeviceViewFieldDetector.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 135). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGH6SJ8wgglOi2hjc-Q&open=AaGH6SJ8wgglOi2hjc-Q&pullRequest=17954

Check warning on line 26 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALFormatProvider.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Abbreviation in name 'WALFormatProvider' must contain no more than '2' consecutive capital letters. 

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

Check failure on line 210 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionSetupHandler.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor this method to reduce its Cognitive Complexity from 19 to the 15 allowed. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGH6QV-wgglOi2hjc9b&open=AaGH6QV-wgglOi2hjc9b&pullRequest=17954

Check failure on line 2197 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/TableDistributedPlanGenerator.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor this method to reduce its Cognitive Complexity from 19 to the 15 allowed. 

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

Check warning on line 39 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALFormatProvider.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Expected @throws tag for 'IOException'. 

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

Check warning on line 56 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/snapshot/SnapshotLoader.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Make this private field "final", it is never reassigned. 

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

Check warning on line 237 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Make this private field "final", it is never reassigned. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGH6R-SwgglOi2hjc-G&open=AaGH6R-SwgglOi2hjc-G&pullRequest=17954

Check warning on line 88 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/LocalExecutionPlanContext.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Make this private field "final", it is never reassigned. 

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

Check warning on line 44 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALFormatProvider.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'}' at column 84 should be alone on a line. 

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

Check failure on line 606 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusSubscriptionSetupHandler.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Refactor this method to reduce its Cognitive Complexity from 26 to the 15 allowed. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGH6QV-wgglOi2hjc9c&open=AaGH6QV-wgglOi2hjc9c&pullRequest=17954
View more details on SonarQubeCloud