Skip to content

Fix active LOAD files stranded when the last worker exits - #19076

Merged
jt2594838 merged 1 commit into
masterfrom
fix/active-load-pending-worker-wakeup
Nov 2, 2026
Merged

Fix active LOAD files stranded when the last worker exits#19076
jt2594838 merged 1 commit into
masterfrom
fix/active-load-pending-worker-wakeup

Fix active LOAD worker retirement leaving files pending

2f8a392
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Nov 2, 2026 in 4m 36s

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 179 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use the "AtomicReference" API for synchronization instead of a "synchronized" block. 

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

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof WALNode walnode' 

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

Check warning on line 169 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.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=AaGbBpklNdy_OzKJykkA&open=AaGbBpklNdy_OzKJykkA&pullRequest=19076

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

Use an "AtomicBoolean" for this field; its operations are atomic. 

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

Check warning on line 215 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadTsFileLoader.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Use the "AtomicReference" API for synchronization instead of a "synchronized" block. 

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