fix some fe ut failed (#8547)

This commit is contained in:
Zhengguo Yang
2022-03-21 10:36:06 +08:00
committed by GitHub
parent c772020db4
commit f06780249a
3 changed files with 3 additions and 3 deletions

View File

@ -77,7 +77,7 @@ public class EsShardPartitions {
singleShardRouting.add(
EsShardRouting.newSearchShard(
(String) indexShard.get("index"),
(Integer) indexShard.get("shard"),
((Long) indexShard.get("shard")).intValue(),
(Boolean) indexShard.get("primary"),
(String) indexShard.get("node"),
(JSONObject) jsonObject.get("nodes")));

View File

@ -116,7 +116,7 @@ public class TempPartitionTest {
private List<List<String>> checkTablet(String tbl, String partitions, boolean isTemp, int expected)
throws Exception {
String showStr = "show tablet from " + tbl + (isTemp ? " temporary" : "") + " partition (" + partitions + ");";
String showStr = "show tablets from " + tbl + (isTemp ? " temporary" : "") + " partition (" + partitions + ");";
ShowTabletStmt showStmt = (ShowTabletStmt) UtFrameUtils.parseAndAnalyzeStmt(showStr, ctx);
ShowExecutor executor = new ShowExecutor(ctx, (ShowStmt) showStmt);
ShowResultSet showResultSet = executor.execute();

View File

@ -125,7 +125,7 @@ public class TruncateTableTest {
}
private List<List<String>> checkShowTabletResultNum(String tbl, String partition, int expected) throws Exception {
String showStr = "show tablet from " + tbl + " partition(" + partition + ")";
String showStr = "show tablets from " + tbl + " partition(" + partition + ")";
ShowTabletStmt showStmt = (ShowTabletStmt) UtFrameUtils.parseAndAnalyzeStmt(showStr, connectContext);
ShowExecutor executor = new ShowExecutor(connectContext, (ShowStmt) showStmt);
ShowResultSet showResultSet = executor.execute();