From 9dc0f80386b1a4fc5ab8a2c45603c032dad47697 Mon Sep 17 00:00:00 2001 From: yujun Date: Thu, 10 Aug 2023 21:41:45 +0800 Subject: [PATCH] [log](tablet clone) add decommission replica log (#22799) --- .../src/main/java/org/apache/doris/clone/TabletScheduler.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java b/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java index 20e0c171f6..1bc2f54337 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java +++ b/fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java @@ -1097,6 +1097,8 @@ public class TabletScheduler extends MasterDaemon { preWatermarkTxnId = Env.getCurrentGlobalTransactionMgr() .getTransactionIDGenerator().getNextTransactionId(); replica.setPreWatermarkTxnId(preWatermarkTxnId); + LOG.info("set decommission replica {} on backend {} of tablet {} pre watermark txn id {}", + replica.getId(), replica.getBackendId(), tabletCtx.getTabletId(), preWatermarkTxnId); } long postWatermarkTxnId = replica.getPostWatermarkTxnId(); @@ -1113,6 +1115,8 @@ public class TabletScheduler extends MasterDaemon { postWatermarkTxnId = Env.getCurrentGlobalTransactionMgr() .getTransactionIDGenerator().getNextTransactionId(); replica.setPostWatermarkTxnId(postWatermarkTxnId); + LOG.info("set decommission replica {} on backend {} of tablet {} post watermark txn id {}", + replica.getId(), replica.getBackendId(), tabletCtx.getTabletId(), postWatermarkTxnId); } try {