From 1ede119f79f42d5801a81121f031ab3be5bd8585 Mon Sep 17 00:00:00 2001 From: koarz Date: Fri, 25 Apr 2025 19:28:02 +0800 Subject: [PATCH] [feat](debugpoint) add a backup block debug point for ccr test (#50380) use for https://github.com/selectdb/ccr-syncer/pull/600 --- .../main/java/org/apache/doris/backup/BackupHandler.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/backup/BackupHandler.java b/fe/fe-core/src/main/java/org/apache/doris/backup/BackupHandler.java index 9a709fa032324d..188e07af5a2826 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/backup/BackupHandler.java +++ b/fe/fe-core/src/main/java/org/apache/doris/backup/BackupHandler.java @@ -46,6 +46,7 @@ import org.apache.doris.common.ErrorReport; import org.apache.doris.common.Pair; import org.apache.doris.common.io.Writable; +import org.apache.doris.common.util.DebugPointUtil; import org.apache.doris.common.util.MasterDaemon; import org.apache.doris.common.util.TimeUtils; import org.apache.doris.fs.FileSystemFactory; @@ -397,6 +398,14 @@ private void backup(Repository repository, Database db, BackupStmt stmt) throws db.readUnlock(); } + while (DebugPointUtil.isEnable("BackupHandler.backup.block")) { + try { + Thread.sleep(100); + } catch (InterruptedException e) { + LOG.info("error ", e); + } + } + List tblRefs = Lists.newArrayList(); if (abstractBackupTableRefClause != null && !abstractBackupTableRefClause.isExclude()) { tblRefs = abstractBackupTableRefClause.getTableRefList();