This is an automated email from the ASF dual-hosted git repository. liyuheng pushed a commit to branch cp/16196 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 11fd78d9cfc24b1bceac862c6ea72933ffd82271 Author: liyuheng <[email protected]> AuthorDate: Fri Aug 22 12:52:11 2025 +0800 spotless --- .../java/org/apache/iotdb/confignode/manager/ProcedureManager.java | 1 - .../plan/execution/config/executor/ClusterConfigTaskExecutor.java | 6 ++---- .../org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java | 1 - 3 files changed, 2 insertions(+), 6 deletions(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java index 197012447e3..5f6450769f5 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java @@ -149,7 +149,6 @@ import java.util.Map; import java.util.Optional; import java.util.Set; import java.util.concurrent.ScheduledExecutorService; -import java.util.concurrent.locks.ReentrantLock; import java.util.function.BiFunction; import java.util.stream.Collectors; import java.util.stream.Stream; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java index d399cf2ea5e..b128f3ba361 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/executor/ClusterConfigTaskExecutor.java @@ -2873,8 +2873,7 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor { CONFIG_NODE_CLIENT_MANAGER.borrowClient(ConfigNodeInfo.CONFIG_REGION_ID)) { final TExtendRegionReq req = new TExtendRegionReq( - extendRegionTask.getStatement().getRegionIds(), - extendRegionTask.getStatement().getDataNodeId() + extendRegionStatement.getRegionIds(), extendRegionStatement.getDataNodeId()); final TSStatus status = configNodeClient.extendRegion(req); if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) { future.setException(new IoTDBException(status.message, status.code)); @@ -2896,8 +2895,7 @@ public class ClusterConfigTaskExecutor implements IConfigTaskExecutor { CONFIG_NODE_CLIENT_MANAGER.borrowClient(ConfigNodeInfo.CONFIG_REGION_ID)) { final TRemoveRegionReq req = new TRemoveRegionReq( - removeRegionTask.getStatement().getRegionIds(), - removeRegionTask.getStatement().getDataNodeId()); + removeRegionStatement.getRegionIds(), removeRegionStatement.getDataNodeId()); final TSStatus status = configNodeClient.removeRegion(req); if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) { future.setException(new IoTDBException(status.message, status.code)); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java index 3ccf328f86a..83304b0c6c2 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java @@ -262,7 +262,6 @@ import java.util.function.Consumer; import java.util.regex.Pattern; import java.util.stream.Collectors; -import static com.google.common.collect.ImmutableList.toImmutableList; import static java.util.stream.Collectors.toList; import static org.apache.iotdb.commons.schema.SchemaConstant.ALL_RESULT_NODES; import static org.apache.iotdb.db.queryengine.plan.optimization.LimitOffsetPushDown.canPushDownLimitOffsetToGroupByTime;
