diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/proc/PartitionsProcDir.java b/fe/fe-core/src/main/java/org/apache/doris/common/proc/PartitionsProcDir.java index 3e7c6bdebc762b..f1aed5b6278960 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/proc/PartitionsProcDir.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/proc/PartitionsProcDir.java @@ -76,6 +76,7 @@ public class PartitionsProcDir implements ProcDirInterface { .add("Buckets").add("ReplicationNum").add("StorageMedium").add("CooldownTime").add("RemoteStoragePolicy") .add("LastConsistencyCheckTime").add("DataSize").add("IsInMemory").add("ReplicaAllocation") .add("IsMutable").add("SyncWithBaseTables").add("UnsyncTables").add("CommittedVersion") + .add("RowCount") .build(); private Database db; @@ -383,6 +384,9 @@ private List, TRow>> getPartitionInfosInrernal() throws An partitionInfo.add(partition.getCommittedVersion()); trow.addToColumnValue(new TCell().setLongVal(partition.getCommittedVersion())); + partitionInfo.add(partition.getRowCount()); + trow.addToColumnValue(new TCell().setLongVal(partition.getRowCount())); + partitionInfos.add(Pair.of(partitionInfo, trow)); } } finally {