Skip to content

[dev/1.3] Fix CQ recovery gap and stale callback contamination#17820

Merged
jt2594838 merged 1 commit into
dev/1.3from
cp-29d0d51-dev-1.3
Jun 3, 2026
Merged

[dev/1.3] Fix CQ recovery gap and stale callback contamination#17820
jt2594838 merged 1 commit into
dev/1.3from
cp-29d0d51-dev-1.3

Fix CQ recovery gap and stale callback contamination (#17734)

943dec0
Select commit
Loading
Failed to load commit list.
SonarQubeCloud / SonarCloud Code Analysis succeeded Jun 2, 2026 in 1m 54s

Annotations

Check warning on line 157 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/CQInfoTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 141 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/CQInfoTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 41 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedureRecoveryTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 61 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/CreateCQProcedureTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 43 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/cq/CQManagerTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 49 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/cq/UpdateCQLastExecTimePlan.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove this use of "notNull"; it is deprecated.

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

Check warning on line 60 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/CreateCQProcedureTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 209 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 109 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/CQInfoTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove the declaration of thrown exception 'java.lang.Exception', as it cannot be thrown from method's body.

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

Check warning on line 235 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 28 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/cq/ShowCQPlan.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Override the "equals" method in this class.

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

Check warning on line 45 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/CreateCQProcedureTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 187 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 141 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/CQInfoTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

Remove the declaration of thrown exception 'java.lang.Exception', as it cannot be thrown from method's body.

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

Check warning on line 39 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/cq/CQManagerTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 39 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedureRecoveryTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check warning on line 19 in iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/cq/CQManagerTest.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

'package' should be separated from previous line.

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

Check warning on line 195 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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

Check failure on line 129 in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/cq/CQManager.java

See this annotation in the file changed.

@sonarqubecloud sonarqubecloud / SonarCloud Code Analysis

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

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