Skip to content

Commit 21cee67

Browse files
authored
[To dev/1.3][remove datanode] Delete the SQL of removing multiple datanodes at the same time (#14879)
* [remove datanode] Delete the SQL of removing multiple datanodes at the same time #14862 (cherry picked from commit b4cec03) * fix compile
1 parent 6a004b2 commit 21cee67

File tree

2 files changed

+5
-8
lines changed

2 files changed

+5
-8
lines changed

iotdb-core/antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -556,7 +556,7 @@ verifyConnection
556556

557557
// ---- Remove DataNode
558558
removeDataNode
559-
: REMOVE DATANODE dataNodeId=INTEGER_LITERAL (COMMA dataNodeId=INTEGER_LITERAL)*
559+
: REMOVE DATANODE dataNodeId=INTEGER_LITERAL
560560
;
561561

562562
// ---- Remove ConfigNode

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -233,7 +233,6 @@
233233
import com.google.common.collect.ImmutableSet;
234234
import com.google.common.io.BaseEncoding;
235235
import org.antlr.v4.runtime.Token;
236-
import org.antlr.v4.runtime.tree.ParseTree;
237236
import org.antlr.v4.runtime.tree.TerminalNode;
238237
import org.apache.tsfile.common.conf.TSFileDescriptor;
239238
import org.apache.tsfile.common.constant.TsFileConstant;
@@ -249,6 +248,7 @@
249248
import java.time.ZoneId;
250249
import java.util.ArrayList;
251250
import java.util.Arrays;
251+
import java.util.Collections;
252252
import java.util.HashMap;
253253
import java.util.HashSet;
254254
import java.util.LinkedHashSet;
@@ -4172,12 +4172,9 @@ public Statement visitRemoveRegion(IoTDBSqlParser.RemoveRegionContext ctx) {
41724172

41734173
@Override
41744174
public Statement visitRemoveDataNode(IoTDBSqlParser.RemoveDataNodeContext ctx) {
4175-
List<Integer> dataNodeIDs =
4176-
ctx.INTEGER_LITERAL().stream()
4177-
.map(ParseTree::getText)
4178-
.map(Integer::parseInt)
4179-
.collect(Collectors.toList());
4180-
return new RemoveDataNodeStatement(dataNodeIDs);
4175+
List<Integer> nodeIds =
4176+
Collections.singletonList(Integer.parseInt(ctx.INTEGER_LITERAL().getText()));
4177+
return new RemoveDataNodeStatement(nodeIds);
41814178
}
41824179

41834180
@Override

0 commit comments

Comments
 (0)