Skip to content

Fix duplicate scheduling in procedure execution#17902

Merged
jt2594838 merged 6 commits into
masterfrom
fix-procedure-duplicate-scheduling
Jun 16, 2026
Merged

Fix duplicate scheduling in procedure execution#17902
jt2594838 merged 6 commits into
masterfrom
fix-procedure-duplicate-scheduling

Merge branch 'master' of https://github.com/apache/iotdb into fix-pro…

bca866a
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis failed Jun 16, 2026 in 2m 51s

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 warning on line 232 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace generic exceptions with specific library exceptions or a custom exception.

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

Check warning on line 73 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/scheduler/SimpleProcedureScheduler.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Provide the parametrized type for this generic.

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

Check warning on line 813 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.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=AZ6xDlUhfFqTS2wWbRPc&open=AZ6xDlUhfFqTS2wWbRPc&pullRequest=17902

Check warning on line 68 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletEventConverter.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Change the visibility of this constructor to "protected".

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

Check warning on line 47 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/TimeoutExecutorThread.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Do something with the "boolean" value returned by "remove".

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

Check warning on line 66 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/TimeoutExecutorThread.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=AZ6xQoIAsClnBOWNLWo3&open=AZ6xQoIAsClnBOWNLWo3&pullRequest=17902

Check warning on line 620 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/AggregateProcessor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace this instanceof check and cast with 'instanceof PipeRowCollector piperowcollector'

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

Check warning on line 846 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.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=AZ7PpCuTAEcTTWTft4ep&open=AZ7PpCuTAEcTTWTft4ep&pullRequest=17902

Check failure on line 65 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/TimeoutExecutorThread.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 226 in iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/partition/DataPartition.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Replace generic exceptions with specific library exceptions or a custom exception.

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

Check warning on line 87 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Class type name 'Env' must match pattern '(^[A-Z][0-9]?)$|([A-Z][a-zA-Z0-9]*[T]$)'.

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

Check warning on line 87 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Rename this generic name to match the regular expression '^[A-Z][0-9]?$'.

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

Check warning on line 273 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/ErrorHandler.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

A "Brain Method" was detected. Refactor it to reduce at least one of the following metrics: LOC from 81 to 64, Complexity from 22 to 14, Nesting Level from 5 to 2, Number of Variables from 17 to 6.

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

Check warning on line 427 in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/AggregateProcessor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

A "Brain Method" was detected. Refactor it to reduce at least one of the following metrics: LOC from 91 to 64, Complexity from 17 to 14, Nesting Level from 4 to 2, Number of Variables from 12 to 6.

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

Check warning on line 826 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureExecutor.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Extract this nested try block into a separate method.

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

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

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

A "Brain Method" was detected. Refactor it to reduce at least one of the following metrics: LOC from 79 to 64, Complexity from 16 to 14, Nesting Level from 4 to 2, Number of Variables from 21 to 6.

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