Skip to content

[Subscription] Flush lingering batch before WAL gap retry - #18785

Merged
jt2594838 merged 1 commit into
masterfrom
wal-fix
Sep 30, 2026
Merged

[Subscription] Flush lingering batch before WAL gap retry#18785
jt2594838 merged 1 commit into
masterfrom
wal-fix

[Subscription] Flush lingering batch before WAL gap retry

1e50448
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Sep 30, 2026 in 2m 44s

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 3688 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 SortNode sortnode' 

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

Check warning on line 716 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 168). 

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

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove this unused method parameter "cachedBlockIndex". 

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

Check warning on line 457 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 ProjectNode projectnode' 

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

Check warning on line 641 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 usage of 'Stream.collect(Collectors.toList())' with 'Stream.toList()' and ensure that the list is unmodified. 

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

Check warning on line 572 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonDescriptor.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=AaDyjPboBxenDX0ixV_F&open=AaDyjPboBxenDX0ixV_F&pullRequest=18785

Check failure on line 3691 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

Fix this access that will throw a NullPointerException when executed. 

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

Check warning on line 38 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TableFunctionOrdering.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

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

Move the conditional expression inside this operation. 

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

Check failure on line 3713 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 29 to the 15 allowed. 

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

Check warning on line 253 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/statemachine/dataregion/DataRegionStateMachine.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=AaDyjQDUBxenDX0ixV_4&open=AaDyjQDUBxenDX0ixV_4&pullRequest=18785

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

Distance between variable 'hasExpectedOutputOrdering' declaration and its first usage is 7, but allowed 3. Consider making that variable final if you still need to store its value in advance (before method calls that might have side effects on the original value). 

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

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

Use "java.util.List.of()" instead. 

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

Check failure on line 3893 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 20 to the 15 allowed. 

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

Check warning on line 3834 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 GroupNode groupnode' 

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

Check warning on line 478 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 TableFunctionProcessorNode tablefunctionprocessornode' 

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

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

Distance between variable 'hasExpectedOutputOrdering' declaration and its first usage is 4, but allowed 3. Consider making that variable final if you still need to store its value in advance (before method calls that might have side effects on the original value). 

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

Check failure on line 249 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/tag/TagManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

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

Use "java.util.List.of()" instead. 

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

Check warning on line 387 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 PreviousFillNode previousfillnode' 

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

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

Move the conditional expression inside this operation. 

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

Check warning on line 223 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/SchemaEngine.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 120). 

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

Check warning on line 271 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueue.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=AaDyjP9JBxenDX0ixV_0&open=AaDyjP9JBxenDX0ixV_0&pullRequest=18785

Check failure on line 425 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 30 to the 15 allowed. 

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

Check warning on line 3875 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 ExternalTsFileScanNode externaltsfilescannode' 

See more on https://sonarcloud.io/project/issues?id=apache_iotdb&issues=AaDyjPuaBxenDX0ixV_j&open=AaDyjPuaBxenDX0ixV_j&pullRequest=18785
View more details on SonarQubeCloud