Skip to content

[Pipe] Allow retry heartbeats past realtime completion barriers - #19219

Open
Caideyipi wants to merge 2 commits into
masterfrom
fix/pipe-retry-heartbeat-barrier
Open

[Pipe] Allow retry heartbeats past realtime completion barriers#19219
Caideyipi wants to merge 2 commits into
masterfrom
fix/pipe-retry-heartbeat-barrier

Fix retry heartbeats blocked by completion barriers

aeb1685
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Nov 11, 2026 in 5m 24s

Quality Gate failed

Failed conditions
B 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 313 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

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=AaHJWOHU1FLQRUDpLKYq&open=AaHJWOHU1FLQRUDpLKYq&pullRequest=19219

Check warning on line 203 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/InsertRowsStatement.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=AaHJWPF91FLQRUDpLKY5&open=AaHJWPF91FLQRUDpLKY5&pullRequest=19219

Check warning on line 125 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/subtask/processor/PipeProcessorSubtaskWorker.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Single-line Javadoc comment should be multi-line. 

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

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

WhitespaceAround: '{' is not followed by whitespace. Empty blocks may only be represented as {} when not part of a multi-block statement (4.1.3) 

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

Check warning on line 250 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileTableSchemaCache.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=AaHJWPk91FLQRUDpLKY-&open=AaHJWPk91FLQRUDpLKY-&pullRequest=19219

Check warning on line 136 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePushConsumerBuilder.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=AaHJWR9Z1FLQRUDpLKZU&open=AaHJWR9Z1FLQRUDpLKZU&pullRequest=19219

Check warning on line 236 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/disk/TierManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use a thread-safe type; adding "volatile" is not enough to make this field thread-safe. 

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

Check warning on line 153 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/InsertMultiTabletsStatement.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=AaHJWPC41FLQRUDpLKY2&open=AaHJWPC41FLQRUDpLKY2&pullRequest=19219

Check warning on line 136 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumerBuilder.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=AaHJWSLv1FLQRUDpLKZb&open=AaHJWSLv1FLQRUDpLKZb&pullRequest=19219

Check warning on line 143 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/DatabasePartitionTable.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Summary javadoc is missing. 

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

Check failure on line 561 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/receiver/SubscriptionReceiverV1.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 39 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/internal/subscription/InternalSubscriptionTablePullConsumerBuilder.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 109). 

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

Check warning on line 78 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/rescon/disk/TierManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use an "AtomicLongArray" instead. 

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

Check warning on line 54 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/internal/session/InternalSession.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check failure on line 42 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/execution/PipeProcessorSubtaskExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove this usage of "super", it is annotated with @VisibleForTesting and should not be accessed from production code. 

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

Check warning on line 134 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePullConsumerBuilder.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=AaHJWR8-1FLQRUDpLKZT&open=AaHJWR8-1FLQRUDpLKZT&pullRequest=19219

Check warning on line 197 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/PipeMetaSyncer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 122). 

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

Check warning on line 66 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTableSessionBuilder.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=AaHJWSOT1FLQRUDpLKZd&open=AaHJWSOT1FLQRUDpLKZd&pullRequest=19219

Check warning on line 65 in iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTreeSessionBuilder.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=AaHJWSOi1FLQRUDpLKZe&open=AaHJWSOi1FLQRUDpLKZe&pullRequest=19219

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

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=AaHJWSBS1FLQRUDpLKZV&open=AaHJWSBS1FLQRUDpLKZV&pullRequest=19219

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof IoTDBException iotdbexception' 

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

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=AaHJWSHW1FLQRUDpLKZX&open=AaHJWSHW1FLQRUDpLKZX&pullRequest=19219

Check warning on line 169 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/InsertRowsOfOneDeviceStatement.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=AaHJWPI41FLQRUDpLKY7&open=AaHJWPI41FLQRUDpLKY7&pullRequest=19219

Check warning on line 127 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/BatchedAlignedValueChunkData.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=AaHJWOUY1FLQRUDpLKYs&open=AaHJWOUY1FLQRUDpLKYs&pullRequest=19219

Check warning on line 250 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileTableSchemaCache.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=AaHJWPk91FLQRUDpLKY_&open=AaHJWPk91FLQRUDpLKY_&pullRequest=19219
View more details on SonarQubeCloud