Skip to content

Preserve subscription progress during consensus leader activation - #19170

Open
Caideyipi wants to merge 6 commits into
masterfrom
codex/fix-consensus-subscription-replay
Open

Preserve subscription progress during consensus leader activation#19170
Caideyipi wants to merge 6 commits into
masterfrom
codex/fix-consensus-subscription-replay

Preserve subscription progress across activation races

d16f351
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Nov 6, 2026 in 10m 23s

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 failure on line 1051 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

Define a constant instead of duplicating this literal "Schema" 4 times. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTfLx-WmSpNyZtnIh&open=AaGwTfLx-WmSpNyZtnIh&pullRequest=19170

Check warning on line 739 in iotdb-client/cli/src/main/java/org/apache/iotdb/cli/AbstractCli.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 103). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTjy7-WmSpNyZtnK1&open=AaGwTjy7-WmSpNyZtnK1&pullRequest=19170

Check warning on line 84 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/TsFileSketchTool.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=AaGwTcj_-WmSpNyZtnHU&open=AaGwTcj_-WmSpNyZtnHU&pullRequest=19170

Check warning on line 114 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/utils/TsFileRewriteOverPrecisedI64Scan.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=AaGwTcsQ-WmSpNyZtnHk&open=AaGwTcsQ-WmSpNyZtnHk&pullRequest=19170

Check warning on line 330 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.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=AaGwTYpj-WmSpNyZtnFZ&open=AaGwTYpj-WmSpNyZtnFZ&pullRequest=19170

Check warning on line 307 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/TsFileWriterManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 176). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTVbq-WmSpNyZtnEQ&open=AaGwTVbq-WmSpNyZtnEQ&pullRequest=19170

Check warning on line 173 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceStateMachine.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=AaGwTYck-WmSpNyZtnFU&open=AaGwTYck-WmSpNyZtnFU&pullRequest=19170

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=AaGwTcDq-WmSpNyZtnHI&open=AaGwTcDq-WmSpNyZtnHI&pullRequest=19170

Check warning on line 138 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 157). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTjbJ-WmSpNyZtnKZ&open=AaGwTjbJ-WmSpNyZtnKZ&pullRequest=19170

Check warning on line 344 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/DataNode.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 197). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTZJ0-WmSpNyZtnFi&open=AaGwTZJ0-WmSpNyZtnFi&pullRequest=19170

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 111). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTf7V-WmSpNyZtnJU&open=AaGwTf7V-WmSpNyZtnJU&pullRequest=19170

Check warning on line 596 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/consensus/ConsensusLogToTabletConverter.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=AaGwTbnV-WmSpNyZtnGq&open=AaGwTbnV-WmSpNyZtnGq&pullRequest=19170

Check warning on line 167 in iotdb-client/cli/src/main/java/org/apache/iotdb/cli/Cli.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 131). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTjt0-WmSpNyZtnKw&open=AaGwTjt0-WmSpNyZtnKw&pullRequest=19170

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 148). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTbyv-WmSpNyZtnGz&open=AaGwTbyv-WmSpNyZtnGz&pullRequest=19170

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=AaGwTf9--WmSpNyZtnJV&open=AaGwTf9--WmSpNyZtnJV&pullRequest=19170

Check warning on line 405 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTaskAgent.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 112). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTS5r-WmSpNyZtnDn&open=AaGwTS5r-WmSpNyZtnDn&pullRequest=19170

Check warning on line 573 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 108). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTbAA-WmSpNyZtnGL&open=AaGwTbAA-WmSpNyZtnGL&pullRequest=19170

Check warning on line 1155 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 111). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTi3m-WmSpNyZtnKC&open=AaGwTi3m-WmSpNyZtnKC&pullRequest=19170

Check warning on line 94 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=AaGwTcpS-WmSpNyZtnHa&open=AaGwTcpS-WmSpNyZtnHa&pullRequest=19170

Check warning on line 161 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/execution/PipeSubtaskExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Either log this exception and handle it, or rethrow it with some contextual information. 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTS80-WmSpNyZtnDr&open=AaGwTS80-WmSpNyZtnDr&pullRequest=19170

Check warning on line 52 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/ListIteratorWrapper.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 103). 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTT-W-WmSpNyZtnD0&open=AaGwTT-W-WmSpNyZtnD0&pullRequest=19170

Check warning on line 58 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/execution/PipeSubtaskExecutorManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof IoTConsensusV2SubtaskExecutor iotconsensusv2subtaskexecutor' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTZXr-WmSpNyZtnFk&open=AaGwTZXr-WmSpNyZtnFk&pullRequest=19170

Check warning on line 1537 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=AaGwTX_y-WmSpNyZtnFG&open=AaGwTX_y-WmSpNyZtnFG&pullRequest=19170

Check warning on line 183 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteDatabaseProcedure.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=AaGwTeY7-WmSpNyZtnIT&open=AaGwTeY7-WmSpNyZtnIT&pullRequest=19170

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

Replace this instanceof check and cast with 'instanceof RuntimeException runtimeexception' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaGwTkTw-WmSpNyZtnLA&open=AaGwTkTw-WmSpNyZtnLA&pullRequest=19170
View more details on SonarQubeCloud