Skip to content

Expose internal client sessions through multiplexed RPC - #19125

Open
shuwenwei wants to merge 33 commits into
masterfrom
feature/internal-rpc-inherit-client-rpc
Open

shuwenwei wants to merge 33 commits into
masterfrom
feature/internal-rpc-inherit-client-rpc

Seed table region before redirect test discovery

e76cc51
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Nov 6, 2026 in 8m 47s

Quality Gate failed

Failed conditions
C Reliability 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 456 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 110).

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

Check warning on line 106 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/utils/TsFileStatisticScan.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use "printf" instead of "String.format".

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

Check warning on line 120 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/recover/file/TsFilePlanRedoer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof TreeDeletionEntry treedeletionentry'

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

Check warning on line 468 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 123).

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

Check failure on line 688 in iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 934 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof IoTDBRuntimeException iotdbruntimeexception'

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGlnl-mAAW_fcC_KPlM&open=AaGlnl-mAAW_fcC_KPlM&pullRequest=19125

Check warning on line 181 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumerBuilder.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 127 in iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/ImportTsFile.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 171).

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

Check warning on line 275 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/trigger/service/TriggerManagementService.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 151).

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

Check warning on line 176 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/validate/TsFileOverlapValidationAndRepairTool.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this use of System.out by a logger.

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

Check warning on line 343 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/DelayAnalyzer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 117).

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

Check warning on line 87 in library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFMad.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 163).

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

Check warning on line 1145 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 172).

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGlnuf-AAW_fcC_KPpz&open=AaGlnuf-AAW_fcC_KPpz&pullRequest=19125

Check warning on line 3072 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImpl.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 144).

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

Check warning on line 698 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 127).

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

Check warning on line 461 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionTopicAgent.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 118).

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

Check warning on line 817 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

Line is longer than 100 characters (found 301).

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

Check warning on line 149 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 104).

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

Check warning on line 143 in iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/Constants.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 108).

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

Check warning on line 1522 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 107).

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

Check warning on line 309 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 130).

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

Check warning on line 1216 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/iotconsensusv2/IoTConsensusV2Receiver.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 107).

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

Check warning on line 37 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/component/IntoComponent.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 134).

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

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 119).

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

Check failure on line 388 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Fix this access that will throw a NullPointerException when executed.

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