This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch cq-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6f7a3373b3b sp
add f09c3b01d5a Fix CQ local schedule cancellation
No new revisions were added by this update.
Summary of changes:
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 4 +-
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 4 +-
.../consensus/request/read/cq/ShowCQPlan.java | 13 +++
.../consensus/request/write/cq/ActiveCQPlan.java | 20 ++--
.../consensus/request/write/cq/AddCQPlan.java | 20 ++--
.../consensus/request/write/cq/DropCQPlan.java | 20 ++--
.../request/write/cq/UpdateCQLastExecTimePlan.java | 23 ++---
.../iotdb/confignode/manager/cq/CQManager.java | 98 +++++++++++++++----
.../confignode/manager/cq/CQScheduleTask.java | 58 +++++++++--
.../iotdb/confignode/persistence/cq/CQInfo.java | 76 +++++++++------
.../persistence/executor/ConfigPlanExecutor.java | 3 +-
.../procedure/impl/cq/CreateCQProcedure.java | 39 ++++----
.../request/ConfigPhysicalPlanSerDeTest.java | 8 +-
.../apache/iotdb/confignode/cq/CQManagerTest.java | 107 +++++++++++++++++++++
.../iotdb/confignode/persistence/CQInfoTest.java | 37 +++++--
.../procedure/impl/CreateCQProcedureTest.java | 2 +-
.../impl/cq/CreateCQProcedureRecoveryTest.java | 13 ++-
17 files changed, 407 insertions(+), 138 deletions(-)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/cq/CQManagerTest.java
