database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[log](tablet clone) add decommission replica log (#22799)

Browse Source
This commit is contained in:
yujun
2023-08-10 21:41:45 +08:00
committed by GitHub
parent a99211d818
commit 9dc0f80386
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/clone/TabletScheduler.java
View File

@ -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 {