This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 952875b437518a7ecdc4b411031874da27545e7d Author: walter <w41te...@gmail.com> AuthorDate: Fri May 24 23:28:01 2024 +0800 [chore](restore) Add logs about the restore table state (#35363) --- fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java b/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java index 2af0242db33..44cd6649fc7 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/backup/RestoreJob.java @@ -2020,6 +2020,7 @@ public class RestoreJob extends AbstractJob { for (String tableName : jobInfo.backupOlapTableObjects.keySet()) { Table tbl = db.getTableNullable(jobInfo.getAliasByOriginNameIfSet(tableName)); if (tbl == null) { + LOG.warn("table {} is not found and skip set state to normal", tableName); continue; } @@ -2034,6 +2035,7 @@ public class RestoreJob extends AbstractJob { try { if (olapTbl.getState() == OlapTableState.RESTORE || olapTbl.getState() == OlapTableState.RESTORE_WITH_LOAD) { + LOG.info("table {} set state from {} to normal", tableName, olapTbl.getState()); olapTbl.setState(OlapTableState.NORMAL); } @@ -2042,6 +2044,8 @@ public class RestoreJob extends AbstractJob { String partitionName = partitionEntry.getKey(); Partition partition = olapTbl.getPartition(partitionName); if (partition == null) { + LOG.warn("table {} partition {} is not found and skip set state to normal", + tableName, partitionName); continue; } if (partition.getState() == PartitionState.RESTORE) { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org