This is an automated email from the ASF dual-hosted git repository. liyuheng pushed a commit to branch lyh/fix-procedure in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d85fc36da973875506285afaf8529a509721ec9a Author: liyuheng <[email protected]> AuthorDate: Thu May 22 13:33:30 2025 +0800 remove ProcedureSuspendedException.java --- .../confignode/procedure/InternalProcedure.java | 4 +-- .../iotdb/confignode/procedure/Procedure.java | 14 ++------ .../exception/ProcedureSuspendedException.java | 39 ---------------------- .../procedure/impl/StateMachineProcedure.java | 5 ++- .../procedure/impl/cq/CreateCQProcedure.java | 3 +- .../procedure/impl/node/RemoveAINodeProcedure.java | 3 +- .../impl/pipe/AbstractOperatePipeProcedureV2.java | 3 +- .../pipe/plugin/CreatePipePluginProcedure.java | 3 +- .../impl/pipe/plugin/DropPipePluginProcedure.java | 3 +- .../impl/region/AddRegionPeerProcedure.java | 3 +- .../region/NotifyRegionMigrationProcedure.java | 3 +- .../impl/region/ReconstructRegionProcedure.java | 3 +- .../impl/region/RemoveRegionPeerProcedure.java | 3 +- .../impl/schema/AlterLogicalViewProcedure.java | 3 +- .../impl/schema/DeactivateTemplateProcedure.java | 3 +- .../impl/schema/DeleteDatabaseProcedure.java | 3 +- .../impl/schema/DeleteLogicalViewProcedure.java | 3 +- .../impl/schema/DeleteTimeSeriesProcedure.java | 3 +- .../procedure/impl/schema/SetTTLProcedure.java | 3 +- .../impl/schema/SetTemplateProcedure.java | 3 +- .../impl/schema/UnsetTemplateProcedure.java | 3 +- .../impl/schema/table/AddTableColumnProcedure.java | 3 +- .../impl/schema/table/CreateTableProcedure.java | 3 +- .../impl/schema/table/DeleteDevicesProcedure.java | 3 +- .../schema/table/DropTableColumnProcedure.java | 3 +- .../impl/schema/table/DropTableProcedure.java | 3 +- .../schema/table/RenameTableColumnProcedure.java | 3 +- .../impl/schema/table/RenameTableProcedure.java | 3 +- .../schema/table/SetTablePropertiesProcedure.java | 3 +- .../AbstractOperateSubscriptionProcedure.java | 3 +- .../impl/sync/AbstractOperatePipeProcedure.java | 3 +- .../AddNeverFinishSubProcedureProcedure.java | 3 +- .../impl/testonly/NeverFinishProcedure.java | 3 +- .../confignode/procedure/entity/IncProcedure.java | 3 +- .../confignode/procedure/entity/NoopProcedure.java | 3 +- .../procedure/entity/SimpleLockProcedure.java | 3 +- .../procedure/entity/SimpleSTMProcedure.java | 3 +- .../procedure/entity/SleepProcedure.java | 3 +- .../procedure/entity/StuckSTMProcedure.java | 3 +- 39 files changed, 40 insertions(+), 127 deletions(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/InternalProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/InternalProcedure.java index 473234304cb..5041c9feac2 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/InternalProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/InternalProcedure.java @@ -19,7 +19,6 @@ package org.apache.iotdb.confignode.procedure; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import java.io.IOException; @@ -38,8 +37,7 @@ public abstract class InternalProcedure<Env> extends Procedure<Env> { protected abstract void periodicExecute(final Env env); @Override - protected Procedure<Env>[] execute(Env env) - throws ProcedureYieldException, ProcedureSuspendedException, InterruptedException { + protected Procedure<Env>[] execute(Env env) throws ProcedureYieldException, InterruptedException { throw new UnsupportedOperationException(); } diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/Procedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/Procedure.java index 97fd6d7e5bf..cb632612822 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/Procedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/Procedure.java @@ -21,7 +21,6 @@ package org.apache.iotdb.confignode.procedure; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.state.ProcedureLockState; import org.apache.iotdb.confignode.procedure.state.ProcedureState; @@ -84,11 +83,9 @@ public abstract class Procedure<Env> implements Comparable<Procedure<Env>> { * @throws ProcedureYieldException the procedure will be added back to the queue and retried * later. * @throws InterruptedException the procedure will be added back to the queue and retried later. - * @throws ProcedureSuspendedException Signal to the executor that Procedure has suspended itself - * and has set itself up waiting for an external event to wake it back up again. */ protected abstract Procedure<Env>[] execute(Env env) - throws ProcedureYieldException, ProcedureSuspendedException, InterruptedException; + throws ProcedureYieldException, InterruptedException; /** * The code to undo what was done by the execute() code. It is called when the procedure or one of @@ -287,7 +284,7 @@ public abstract class Procedure<Env> implements Comparable<Procedure<Env>> { * @return sub procedures */ protected Procedure<Env>[] doExecute(Env env) - throws ProcedureYieldException, ProcedureSuspendedException, InterruptedException { + throws ProcedureYieldException, InterruptedException { try { updateTimestamp(); return execute(env); @@ -681,13 +678,6 @@ public abstract class Procedure<Env> implements Comparable<Procedure<Env>> { /** * Called by the ProcedureExecutor when the timeout set by setTimeout() is expired. * - * <p>Another usage for this method is to implement retrying. A procedure can set the state to - * {@code WAITING_TIMEOUT} by calling {@code setState} method, and throw a {@link - * ProcedureSuspendedException} to halt the execution of the procedure, and do not forget a call - * {@link #setTimeout(long)} method to set the timeout. And you should also override this method - * to wake up the procedure, and also return false to tell the ProcedureExecutor that the timeout - * event has been handled. - * * @return true to let the framework handle the timeout as abort, false in case the procedure * handled the timeout itself. */ diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/exception/ProcedureSuspendedException.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/exception/ProcedureSuspendedException.java deleted file mode 100644 index 1b6f049bd48..00000000000 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/exception/ProcedureSuspendedException.java +++ /dev/null @@ -1,39 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.iotdb.confignode.procedure.exception; - -public class ProcedureSuspendedException extends ProcedureException { - - private static final long serialVersionUID = -8328419627678496269L; - - /** default constructor */ - public ProcedureSuspendedException() { - super(); - } - - /** - * Constructor - * - * @param s message - */ - public ProcedureSuspendedException(String s) { - super(s); - } -} diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/StateMachineProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/StateMachineProcedure.java index aaae9814407..f6b15ce7a7b 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/StateMachineProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/StateMachineProcedure.java @@ -21,7 +21,6 @@ package org.apache.iotdb.confignode.procedure.impl; import org.apache.iotdb.confignode.procedure.Procedure; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.thrift.annotation.Nullable; @@ -91,7 +90,7 @@ public abstract class StateMachineProcedure<Env, TState> extends Procedure<Env> * another step. */ protected abstract Flow executeFromState(Env env, TState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException; + throws ProcedureYieldException, InterruptedException; /** * Called to perform the rollback of the specified state. @@ -145,7 +144,7 @@ public abstract class StateMachineProcedure<Env, TState> extends Procedure<Env> @Override protected Procedure<Env>[] execute(final Env env) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { updateTimestamp(); try { if (noMoreState() || isFailed()) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java index 579f51612ba..14b039d1dcf 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java @@ -28,7 +28,6 @@ import org.apache.iotdb.confignode.consensus.request.write.cq.DropCQPlan; import org.apache.iotdb.confignode.manager.cq.CQScheduleTask; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.node.AbstractNodeProcedure; import org.apache.iotdb.confignode.procedure.state.cq.CreateCQState; @@ -84,7 +83,7 @@ public class CreateCQProcedure extends AbstractNodeProcedure<CreateCQState> { @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, CreateCQState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveAINodeProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveAINodeProcedure.java index 03ea4b13a27..76903142686 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveAINodeProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveAINodeProcedure.java @@ -26,7 +26,6 @@ import org.apache.iotdb.confignode.consensus.request.write.ainode.RemoveAINodePl import org.apache.iotdb.confignode.consensus.request.write.model.DropModelInNodePlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.state.RemoveAINodeState; import org.apache.iotdb.confignode.procedure.store.ProcedureType; @@ -58,7 +57,7 @@ public class RemoveAINodeProcedure extends AbstractNodeProcedure<RemoveAINodeSta @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, RemoveAINodeState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { if (removedAINode == null) { return Flow.NO_MORE_STATE; } diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java index d8b03991a4e..26c44605ba4 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/AbstractOperatePipeProcedureV2.java @@ -26,7 +26,6 @@ import org.apache.iotdb.confignode.manager.pipe.metric.overview.PipeProcedureMet import org.apache.iotdb.confignode.persistence.pipe.PipeTaskInfo; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.node.AbstractNodeProcedure; import org.apache.iotdb.confignode.procedure.impl.pipe.runtime.PipeMetaSyncProcedure; @@ -223,7 +222,7 @@ public abstract class AbstractOperatePipeProcedureV2 @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, OperatePipeTaskState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { if (pipeTaskInfo == null) { LOGGER.warn( "ProcedureId {}: Pipe lock is not acquired, executeFromState's execution will be skipped.", diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java index 3b20fee4d2b..d4dbf6aabee 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java @@ -28,7 +28,6 @@ import org.apache.iotdb.confignode.manager.ConfigManager; import org.apache.iotdb.confignode.manager.pipe.coordinator.plugin.PipePluginCoordinator; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.node.AbstractNodeProcedure; import org.apache.iotdb.confignode.procedure.impl.node.AddConfigNodeProcedure; @@ -85,7 +84,7 @@ public class CreatePipePluginProcedure extends AbstractNodeProcedure<CreatePipeP @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, CreatePipePluginState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { if (pipePluginMeta == null) { return Flow.NO_MORE_STATE; } diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java index ca949576cc1..aadf4d1aee8 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java @@ -27,7 +27,6 @@ import org.apache.iotdb.confignode.persistence.pipe.PipeTaskInfo; import org.apache.iotdb.confignode.persistence.subscription.SubscriptionInfo; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.node.AbstractNodeProcedure; import org.apache.iotdb.confignode.procedure.impl.node.AddConfigNodeProcedure; @@ -82,7 +81,7 @@ public class DropPipePluginProcedure extends AbstractNodeProcedure<DropPipePlugi @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, DropPipePluginState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { if (pluginName == null) { return Flow.NO_MORE_STATE; } diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/AddRegionPeerProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/AddRegionPeerProcedure.java index 3da3e0e8abb..d9d368ea773 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/AddRegionPeerProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/AddRegionPeerProcedure.java @@ -29,7 +29,6 @@ import org.apache.iotdb.commons.utils.ThriftCommonsSerDeUtils; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.env.RegionMaintainHandler; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.state.AddRegionPeerState; import org.apache.iotdb.confignode.procedure.store.ProcedureType; @@ -75,7 +74,7 @@ public class AddRegionPeerProcedure extends RegionOperationProcedure<AddRegionPe @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, AddRegionPeerState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { if (regionId == null) { return Flow.NO_MORE_STATE; } diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/NotifyRegionMigrationProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/NotifyRegionMigrationProcedure.java index 0160e9116f9..79fa63f2de1 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/NotifyRegionMigrationProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/NotifyRegionMigrationProcedure.java @@ -24,7 +24,6 @@ import org.apache.iotdb.commons.exception.runtime.ThriftSerDeException; import org.apache.iotdb.commons.utils.ThriftCommonsSerDeUtils; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.state.NotifyRegionMigrationState; import org.apache.iotdb.confignode.procedure.store.ProcedureType; @@ -56,7 +55,7 @@ public class NotifyRegionMigrationProcedure @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, NotifyRegionMigrationState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { if (regionId == null) { return Flow.NO_MORE_STATE; } diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/ReconstructRegionProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/ReconstructRegionProcedure.java index 003e0c407b1..851dfafcc28 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/ReconstructRegionProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/ReconstructRegionProcedure.java @@ -26,7 +26,6 @@ import org.apache.iotdb.commons.utils.CommonDateTimeUtils; import org.apache.iotdb.commons.utils.ThriftCommonsSerDeUtils; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.state.ReconstructRegionState; import org.apache.iotdb.confignode.procedure.store.ProcedureType; @@ -57,7 +56,7 @@ public class ReconstructRegionProcedure extends RegionOperationProcedure<Reconst @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, ReconstructRegionState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { try { switch (state) { case RECONSTRUCT_REGION_PREPARE: diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionPeerProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionPeerProcedure.java index 64905361250..7e5ed5e3cd2 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionPeerProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/RemoveRegionPeerProcedure.java @@ -30,7 +30,6 @@ import org.apache.iotdb.commons.utils.ThriftCommonsSerDeUtils; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.env.RegionMaintainHandler; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.state.RemoveRegionPeerState; import org.apache.iotdb.confignode.procedure.store.ProcedureType; @@ -82,7 +81,7 @@ public class RemoveRegionPeerProcedure extends RegionOperationProcedure<RemoveRe @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, RemoveRegionPeerState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { if (regionId == null) { return Flow.NO_MORE_STATE; } diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterLogicalViewProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterLogicalViewProcedure.java index e81df1e558a..c25079c2f91 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterLogicalViewProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterLogicalViewProcedure.java @@ -35,7 +35,6 @@ import org.apache.iotdb.confignode.client.async.CnToDnInternalServiceAsyncReques import org.apache.iotdb.confignode.client.async.handlers.DataNodeAsyncRequestContext; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.state.schema.AlterLogicalViewState; @@ -91,7 +90,7 @@ public class AlterLogicalViewProcedure @Override protected Flow executeFromState( final ConfigNodeProcedureEnv env, final AlterLogicalViewState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { final long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeactivateTemplateProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeactivateTemplateProcedure.java index cffa43f3f73..90c3df2021f 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeactivateTemplateProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeactivateTemplateProcedure.java @@ -35,7 +35,6 @@ import org.apache.iotdb.confignode.consensus.request.write.pipe.payload.PipeDeac import org.apache.iotdb.confignode.consensus.request.write.pipe.payload.PipeEnrichedPlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.state.schema.DeactivateTemplateState; @@ -97,7 +96,7 @@ public class DeactivateTemplateProcedure @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, DeactivateTemplateState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteDatabaseProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteDatabaseProcedure.java index 652ccc75a24..e589bc0eb04 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteDatabaseProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteDatabaseProcedure.java @@ -36,7 +36,6 @@ import org.apache.iotdb.confignode.manager.partition.PartitionMetrics; import org.apache.iotdb.confignode.persistence.partition.maintainer.RegionDeleteTask; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.state.schema.DeleteStorageGroupState; @@ -86,7 +85,7 @@ public class DeleteDatabaseProcedure @Override protected Flow executeFromState( final ConfigNodeProcedureEnv env, final DeleteStorageGroupState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { if (deleteDatabaseSchema == null) { return Flow.NO_MORE_STATE; } diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteLogicalViewProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteLogicalViewProcedure.java index 6b67da9aab9..6edb7c72f07 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteLogicalViewProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteLogicalViewProcedure.java @@ -33,7 +33,6 @@ import org.apache.iotdb.confignode.consensus.request.write.pipe.payload.PipeDele import org.apache.iotdb.confignode.consensus.request.write.pipe.payload.PipeEnrichedPlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.state.schema.DeleteLogicalViewState; @@ -92,7 +91,7 @@ public class DeleteLogicalViewProcedure @Override protected Flow executeFromState( final ConfigNodeProcedureEnv env, final DeleteLogicalViewState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteTimeSeriesProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteTimeSeriesProcedure.java index b92a675c60e..bebab547cc2 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteTimeSeriesProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DeleteTimeSeriesProcedure.java @@ -33,7 +33,6 @@ import org.apache.iotdb.confignode.consensus.request.write.pipe.payload.PipeDele import org.apache.iotdb.confignode.consensus.request.write.pipe.payload.PipeEnrichedPlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.state.schema.DeleteTimeSeriesState; @@ -97,7 +96,7 @@ public class DeleteTimeSeriesProcedure @Override protected Flow executeFromState( final ConfigNodeProcedureEnv env, final DeleteTimeSeriesState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { final long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTTLProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTTLProcedure.java index de81a0681a1..b4cff74cf2d 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTTLProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTTLProcedure.java @@ -32,7 +32,6 @@ import org.apache.iotdb.confignode.consensus.request.write.database.SetTTLPlan; import org.apache.iotdb.confignode.consensus.request.write.pipe.payload.PipeEnrichedPlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.state.schema.SetTTLState; @@ -67,7 +66,7 @@ public class SetTTLProcedure extends StateMachineProcedure<ConfigNodeProcedureEn @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, SetTTLState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java index 9180904cade..e6bb4328172 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/SetTemplateProcedure.java @@ -39,7 +39,6 @@ import org.apache.iotdb.confignode.consensus.request.write.template.PreSetSchema import org.apache.iotdb.confignode.consensus.response.template.TemplateInfoResp; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.state.schema.SetTemplateState; @@ -100,7 +99,7 @@ public class SetTemplateProcedure @Override protected Flow executeFromState(final ConfigNodeProcedureEnv env, final SetTemplateState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/UnsetTemplateProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/UnsetTemplateProcedure.java index 5883db04dc1..6da9dd48322 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/UnsetTemplateProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/UnsetTemplateProcedure.java @@ -31,7 +31,6 @@ import org.apache.iotdb.confignode.client.async.CnToDnInternalServiceAsyncReques import org.apache.iotdb.confignode.client.async.handlers.DataNodeAsyncRequestContext; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.state.schema.UnsetTemplateState; @@ -86,7 +85,7 @@ public class UnsetTemplateProcedure @Override protected Flow executeFromState(final ConfigNodeProcedureEnv env, final UnsetTemplateState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { final long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AddTableColumnProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AddTableColumnProcedure.java index d75cf6e18e6..5b57d70f91f 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AddTableColumnProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AddTableColumnProcedure.java @@ -29,7 +29,6 @@ import org.apache.iotdb.confignode.consensus.request.write.table.AddTableColumnP import org.apache.iotdb.confignode.consensus.request.write.table.view.AddTableViewColumnPlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.schema.table.view.AddViewColumnProcedure; import org.apache.iotdb.confignode.procedure.state.schema.AddTableColumnState; @@ -68,7 +67,7 @@ public class AddTableColumnProcedure @Override protected Flow executeFromState(final ConfigNodeProcedureEnv env, final AddTableColumnState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { final long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/CreateTableProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/CreateTableProcedure.java index 4894f5db4ca..a4561c1614e 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/CreateTableProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/CreateTableProcedure.java @@ -30,7 +30,6 @@ import org.apache.iotdb.confignode.consensus.request.write.table.RollbackCreateT import org.apache.iotdb.confignode.exception.DatabaseNotExistsException; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.impl.schema.SchemaUtils; @@ -73,7 +72,7 @@ public class CreateTableProcedure @Override protected Flow executeFromState(final ConfigNodeProcedureEnv env, final CreateTableState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { final long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DeleteDevicesProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DeleteDevicesProcedure.java index 0602a9166fc..afd7a309e2a 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DeleteDevicesProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DeleteDevicesProcedure.java @@ -33,7 +33,6 @@ import org.apache.iotdb.confignode.consensus.request.write.pipe.payload.PipeEnri import org.apache.iotdb.confignode.manager.ClusterManager; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.schema.DataNodeRegionTaskExecutor; import org.apache.iotdb.confignode.procedure.state.schema.DeleteDevicesState; @@ -97,7 +96,7 @@ public class DeleteDevicesProcedure extends AbstractAlterOrDropTableProcedure<De @Override protected Flow executeFromState(final ConfigNodeProcedureEnv env, final DeleteDevicesState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { final long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableColumnProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableColumnProcedure.java index 9b39f421c44..49566767143 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableColumnProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableColumnProcedure.java @@ -34,7 +34,6 @@ import org.apache.iotdb.confignode.consensus.request.write.table.view.CommitDele import org.apache.iotdb.confignode.consensus.request.write.table.view.PreDeleteViewColumnPlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.schema.SchemaUtils; import org.apache.iotdb.confignode.procedure.impl.schema.table.view.DropViewColumnProcedure; @@ -85,7 +84,7 @@ public class DropTableColumnProcedure @Override protected Flow executeFromState( final ConfigNodeProcedureEnv env, final DropTableColumnState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { final long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableProcedure.java index 54bf389b96b..c0e68568f88 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/DropTableProcedure.java @@ -34,7 +34,6 @@ import org.apache.iotdb.confignode.consensus.request.write.table.view.CommitDele import org.apache.iotdb.confignode.consensus.request.write.table.view.PreDeleteViewPlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.schema.SchemaUtils; import org.apache.iotdb.confignode.procedure.impl.schema.table.view.DropViewProcedure; @@ -76,7 +75,7 @@ public class DropTableProcedure extends AbstractAlterOrDropTableProcedure<DropTa @Override protected Flow executeFromState(final ConfigNodeProcedureEnv env, final DropTableState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { final long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableColumnProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableColumnProcedure.java index 76be83f89be..d738eda26a8 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableColumnProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableColumnProcedure.java @@ -27,7 +27,6 @@ import org.apache.iotdb.confignode.consensus.request.write.table.RenameTableColu import org.apache.iotdb.confignode.consensus.request.write.table.view.RenameViewColumnPlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.schema.table.view.RenameViewColumnProcedure; import org.apache.iotdb.confignode.procedure.state.schema.RenameTableColumnState; @@ -70,7 +69,7 @@ public class RenameTableColumnProcedure @Override protected Flow executeFromState( final ConfigNodeProcedureEnv env, final RenameTableColumnState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { final long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableProcedure.java index bc129ad40e9..a9c26895413 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/RenameTableProcedure.java @@ -27,7 +27,6 @@ import org.apache.iotdb.confignode.consensus.request.write.table.RenameTablePlan import org.apache.iotdb.confignode.consensus.request.write.table.view.RenameViewPlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.schema.table.view.RenameViewProcedure; import org.apache.iotdb.confignode.procedure.state.schema.RenameTableState; @@ -63,7 +62,7 @@ public class RenameTableProcedure extends AbstractAlterOrDropTableProcedure<Rena @Override protected Flow executeFromState(final ConfigNodeProcedureEnv env, final RenameTableState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { final long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTablePropertiesProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTablePropertiesProcedure.java index aeed916f026..8e220af81cc 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTablePropertiesProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTablePropertiesProcedure.java @@ -27,7 +27,6 @@ import org.apache.iotdb.confignode.consensus.request.write.table.SetTablePropert import org.apache.iotdb.confignode.consensus.request.write.table.view.SetViewPropertiesPlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.schema.table.view.SetViewPropertiesProcedure; import org.apache.iotdb.confignode.procedure.state.schema.SetTablePropertiesState; @@ -76,7 +75,7 @@ public class SetTablePropertiesProcedure @Override protected Flow executeFromState( final ConfigNodeProcedureEnv env, final SetTablePropertiesState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { final long startTime = System.currentTimeMillis(); try { switch (state) { diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/AbstractOperateSubscriptionProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/AbstractOperateSubscriptionProcedure.java index dcefa8d5f45..ad7a0aa876c 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/AbstractOperateSubscriptionProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/AbstractOperateSubscriptionProcedure.java @@ -24,7 +24,6 @@ import org.apache.iotdb.commons.subscription.meta.topic.TopicMeta; import org.apache.iotdb.confignode.persistence.subscription.SubscriptionInfo; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.node.AbstractNodeProcedure; import org.apache.iotdb.confignode.procedure.impl.subscription.consumer.runtime.ConsumerGroupMetaSyncProcedure; @@ -181,7 +180,7 @@ public abstract class AbstractOperateSubscriptionProcedure @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, OperateSubscriptionState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { if (subscriptionInfo == null) { LOGGER.warn( "ProcedureId {}: Subscription lock is not acquired, executeFromState({})'s execution will be skipped.", diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AbstractOperatePipeProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AbstractOperatePipeProcedure.java index 4f92525f0ad..ed45b018e48 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AbstractOperatePipeProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/sync/AbstractOperatePipeProcedure.java @@ -21,7 +21,6 @@ package org.apache.iotdb.confignode.procedure.impl.sync; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.impl.pipe.AbstractOperatePipeProcedureV2; @@ -40,7 +39,7 @@ abstract class AbstractOperatePipeProcedure @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, OperatePipeState state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { return Flow.NO_MORE_STATE; } diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/testonly/AddNeverFinishSubProcedureProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/testonly/AddNeverFinishSubProcedureProcedure.java index e615eaf7f27..66171c91ec8 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/testonly/AddNeverFinishSubProcedureProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/testonly/AddNeverFinishSubProcedureProcedure.java @@ -22,7 +22,6 @@ package org.apache.iotdb.confignode.procedure.impl.testonly; import org.apache.iotdb.commons.utils.TestOnly; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.store.ProcedureType; @@ -42,7 +41,7 @@ public class AddNeverFinishSubProcedureProcedure @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, Integer state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { if (state == 0) { // the sub procedure will never finish, so the father procedure should never be called again addChildProcedure(new NeverFinishProcedure()); diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/testonly/NeverFinishProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/testonly/NeverFinishProcedure.java index 7b247bc6588..3f259519d0a 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/testonly/NeverFinishProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/testonly/NeverFinishProcedure.java @@ -22,7 +22,6 @@ package org.apache.iotdb.confignode.procedure.impl.testonly; import org.apache.iotdb.commons.utils.TestOnly; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; import org.apache.iotdb.confignode.procedure.store.ProcedureType; @@ -42,7 +41,7 @@ public class NeverFinishProcedure extends StateMachineProcedure<ConfigNodeProced @Override protected Flow executeFromState(ConfigNodeProcedureEnv env, Integer state) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { setNextState(state + 1); Thread.sleep(1000); return Flow.HAS_MORE_STATE; diff --git a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/IncProcedure.java b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/IncProcedure.java index d85e40522a0..42c14b2ae5b 100644 --- a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/IncProcedure.java +++ b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/IncProcedure.java @@ -21,7 +21,6 @@ package org.apache.iotdb.confignode.procedure.entity; import org.apache.iotdb.confignode.procedure.Procedure; import org.apache.iotdb.confignode.procedure.env.TestProcEnv; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import java.io.DataOutputStream; @@ -34,7 +33,7 @@ public class IncProcedure extends Procedure<TestProcEnv> { @Override protected Procedure<TestProcEnv>[] execute(TestProcEnv testProcEnv) - throws ProcedureYieldException, ProcedureSuspendedException, InterruptedException { + throws ProcedureYieldException, InterruptedException { AtomicInteger acc = testProcEnv.getAcc(); if (throwEx) { throw new RuntimeException("throw a EXCEPTION"); diff --git a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/NoopProcedure.java b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/NoopProcedure.java index 159ee6f1077..4d2c070b804 100644 --- a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/NoopProcedure.java +++ b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/NoopProcedure.java @@ -21,7 +21,6 @@ package org.apache.iotdb.confignode.procedure.entity; import org.apache.iotdb.confignode.procedure.Procedure; import org.apache.iotdb.confignode.procedure.env.TestProcEnv; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import java.io.IOException; @@ -30,7 +29,7 @@ public class NoopProcedure extends Procedure<TestProcEnv> { @Override protected Procedure<TestProcEnv>[] execute(TestProcEnv testProcEnv) - throws ProcedureYieldException, ProcedureSuspendedException, InterruptedException { + throws ProcedureYieldException, InterruptedException { return new Procedure[0]; } diff --git a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SimpleLockProcedure.java b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SimpleLockProcedure.java index 9675df1f067..44d1bcab8e6 100644 --- a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SimpleLockProcedure.java +++ b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SimpleLockProcedure.java @@ -21,7 +21,6 @@ package org.apache.iotdb.confignode.procedure.entity; import org.apache.iotdb.confignode.procedure.Procedure; import org.apache.iotdb.confignode.procedure.env.TestProcEnv; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.scheduler.SimpleProcedureScheduler; import org.apache.iotdb.confignode.procedure.state.ProcedureLockState; @@ -40,7 +39,7 @@ public class SimpleLockProcedure extends Procedure<TestProcEnv> { @Override protected Procedure<TestProcEnv>[] execute(TestProcEnv testProcEnv) - throws ProcedureYieldException, ProcedureSuspendedException, InterruptedException { + throws ProcedureYieldException, InterruptedException { testProcEnv.executeSeq.append(procName); return null; } diff --git a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SimpleSTMProcedure.java b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SimpleSTMProcedure.java index 6464ee018a0..9296c05106e 100644 --- a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SimpleSTMProcedure.java +++ b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SimpleSTMProcedure.java @@ -21,7 +21,6 @@ package org.apache.iotdb.confignode.procedure.entity; import org.apache.iotdb.confignode.procedure.env.TestProcEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; @@ -41,7 +40,7 @@ public class SimpleSTMProcedure @Override protected Flow executeFromState(TestProcEnv testProcEnv, TestState testState) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { AtomicInteger acc = testProcEnv.getAcc(); try { switch (testState) { diff --git a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SleepProcedure.java b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SleepProcedure.java index 26a9a9afe61..249ef8f7dd8 100644 --- a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SleepProcedure.java +++ b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/SleepProcedure.java @@ -21,7 +21,6 @@ package org.apache.iotdb.confignode.procedure.entity; import org.apache.iotdb.confignode.procedure.Procedure; import org.apache.iotdb.confignode.procedure.env.TestProcEnv; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.util.ProcedureTestUtil; @@ -31,7 +30,7 @@ import java.io.IOException; public class SleepProcedure extends Procedure<TestProcEnv> { @Override protected Procedure<TestProcEnv>[] execute(TestProcEnv testProcEnv) - throws ProcedureYieldException, ProcedureSuspendedException, InterruptedException { + throws ProcedureYieldException, InterruptedException { System.out.println("Procedure is sleeping."); ProcedureTestUtil.sleepWithoutInterrupt(2000); return null; diff --git a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/StuckSTMProcedure.java b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/StuckSTMProcedure.java index 41dd5a342ea..9bcea7da725 100644 --- a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/StuckSTMProcedure.java +++ b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/StuckSTMProcedure.java @@ -21,7 +21,6 @@ package org.apache.iotdb.confignode.procedure.entity; import org.apache.iotdb.confignode.procedure.env.TestProcEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.exception.ProcedureSuspendedException; import org.apache.iotdb.confignode.procedure.exception.ProcedureYieldException; import org.apache.iotdb.confignode.procedure.impl.StateMachineProcedure; @@ -48,7 +47,7 @@ public class StuckSTMProcedure @Override protected Flow executeFromState(TestProcEnv testProcEnv, TestState testState) - throws ProcedureSuspendedException, ProcedureYieldException, InterruptedException { + throws ProcedureYieldException, InterruptedException { AtomicInteger acc = testProcEnv.getAcc(); try { switch (testState) {
