tool
/
starrocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Enhancement] enhance drop partition log information (backport #61787) (#61962) 

Signed-off-by: crossoverJie <crossoverJie@gmail.com>
Co-authored-by: crossoverJie <crossoverJie@gmail.com>
Co-authored-by: wyb <wybb86@gmail.com>
This commit is contained in:
mergify[bot] 2025-08-15 14:04:15 +08:00 committed by GitHub
parent 3708c97461
commit f5a74aa16d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
fe/fe-core/src/main/java/com/starrocks/server/LocalMetastore.java
View File

@ -1385,7 +1385,9 @@ public class LocalMetastore implements ConnectorMetadata, MVRepairHandler, Memor
DropPartitionsInfo info =
new DropPartitionsInfo(dbId, tableId, isTempPartition, clause.isForceDrop(), null, true);
editLog.logDropPartitions(info);
LOG.info("succeed in dropping all partitions, is temp : {}, is force : {}", isTempPartition,
LOG.info("succeed in dropping all partitions, db: {}, table: {}, is temp: {}, is force: {}",
db.getFullName(), olapTable.getName(),
isTempPartition,
clause.isForceDrop());
return;
}
@ -1466,13 +1468,17 @@ public class LocalMetastore implements ConnectorMetadata, MVRepairHandler, Memor
String partitionName = clause.getPartitionName();
DropPartitionInfo info = new DropPartitionInfo(dbId, tableId, partitionName, isTempPartition, clause.isForceDrop());
editLog.logDropPartition(info);
LOG.info("succeed in dropping partition[{}], is temp : {}, is force : {}", partitionName, isTempPartition,
LOG.info("succeed in dropping partition[{}], db: {}, table: {}, is temp : {}, is force : {}", partitionName,
db.getFullName(), olapTable.getName(),
isTempPartition,
clause.isForceDrop());
} else {
DropPartitionsInfo info =
new DropPartitionsInfo(dbId, tableId, isTempPartition, clause.isForceDrop(), existPartitions);
editLog.logDropPartitions(info);
LOG.info("succeed in dropping partitions[{}], is temp : {}, is force : {}", existPartitions, isTempPartition,
LOG.info("succeed in dropping partitions[{}], db: {}, table: {}, is temp : {}, is force : {}", existPartitions,
db.getFullName(), olapTable.getName(),
isTempPartition,
clause.isForceDrop());
}