Skip to content

Allow heartbeat retries while a realtime TsFile is in flight - #19075

Merged
jt2594838 merged 2 commits into
masterfrom
codex/fix-pipe-region-downgrading-retry
Nov 2, 2026
Merged

Allow heartbeat retries while a realtime TsFile is in flight#19075
jt2594838 merged 2 commits into
masterfrom
codex/fix-pipe-region-downgrading-retry

Fix heartbeat ordering test setup

068f330
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Nov 2, 2026 in 8m 10s

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 178 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionBrokerAgent.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=AaGbWeS_kthyPTtDyGzm&open=AaGbWeS_kthyPTtDyGzm&pullRequest=19075

Check warning on line 454 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/thrift/sync/IoTDBDataRegionSyncSink.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=AaGbWcrAkthyPTtDyGyg&open=AaGbWcrAkthyPTtDyGyg&pullRequest=19075

Check warning on line 422 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/sink/client/IoTDBSyncClientManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 129). 

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

Check warning on line 393 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=AaGbWYCYkthyPTtDyGxD&open=AaGbWYCYkthyPTtDyGxD&pullRequest=19075

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 188). 

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

Check warning on line 495 in iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/WindowsDiskMetricsManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 105). 

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

Check warning on line 74 in iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/unary/scalar/BytesToDoubleColumnTransformer.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 124). 

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

Check warning on line 98 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=AaGbWe77kthyPTtDyG0V&open=AaGbWe77kthyPTtDyG0V&pullRequest=19075

Check failure on line 1050 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=AaGbWg3WkthyPTtDyG1C&open=AaGbWg3WkthyPTtDyG1C&pullRequest=19075

Check warning on line 611 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 139). 

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

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=AaGbWbfekthyPTtDyGyB&open=AaGbWbfekthyPTtDyGyB&pullRequest=19075

Check warning on line 698 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 172). 

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

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Line is longer than 100 characters (found 220). 

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

Check warning on line 142 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingTabletQueue.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=AaGbWeOXkthyPTtDyGzh&open=AaGbWeOXkthyPTtDyGzh&pullRequest=19075

Check warning on line 2489 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 114). 

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

Check warning on line 304 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=AaGbWdedkthyPTtDyGyt&open=AaGbWdedkthyPTtDyGyt&pullRequest=19075

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=AaGbWdnGkthyPTtDyGy9&open=AaGbWdnGkthyPTtDyGy9&pullRequest=19075

Check warning on line 1266 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 178). 

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

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

Replace this use of System.out by a logger. 

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

Check warning on line 676 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/partition/DataPartitionTableIntegrityCheckProcedure.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=AaGbWgkMkthyPTtDyG08&open=AaGbWgkMkthyPTtDyG08&pullRequest=19075

Check warning on line 354 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionBrokerAgent.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=AaGbWeS_kthyPTtDyGzn&open=AaGbWeS_kthyPTtDyGzn&pullRequest=19075

Check warning on line 293 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 107). 

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

Check warning on line 63 in library-udf/src/main/java/org/apache/iotdb/library/string/UDTFRegexReplace.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=AaGbWjOAkthyPTtDyG2P&open=AaGbWjOAkthyPTtDyG2P&pullRequest=19075

Check warning on line 114 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=AaGbWesukthyPTtDyG0E&open=AaGbWesukthyPTtDyG0E&pullRequest=19075

Check warning on line 56 in library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDTFMinMax.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=AaGbWiZEkthyPTtDyG2J&open=AaGbWiZEkthyPTtDyG2J&pullRequest=19075
View more details on SonarQubeCloud