diff --git a/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsShardPartitions.java b/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsShardPartitions.java index 710e6832e4..967cf18eea 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsShardPartitions.java +++ b/fe/fe-core/src/main/java/org/apache/doris/external/elasticsearch/EsShardPartitions.java @@ -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"))); diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/TempPartitionTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/TempPartitionTest.java index b587730953..ffd3528a56 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/TempPartitionTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/TempPartitionTest.java @@ -116,7 +116,7 @@ public class TempPartitionTest { private List> 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(); diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/TruncateTableTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/TruncateTableTest.java index 15a8f82412..db8951da4e 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/TruncateTableTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/TruncateTableTest.java @@ -125,7 +125,7 @@ public class TruncateTableTest { } private List> 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();