This is an automated email from the ASF dual-hosted git repository. xingtanzjr pushed a commit to branch xingtanzjr/migration_add_wait_sync in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 74c5ee4b7d94051e08351236ba1a0cad6edc0e7c Author: Jinrui.Zhang <[email protected]> AuthorDate: Thu Oct 27 16:47:10 2022 +0800 complete wait logic when migrate dataregion for ML --- .../apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java index dc4ee7007b..80957fb29a 100644 --- a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java +++ b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java @@ -491,6 +491,11 @@ public class MultiLeaderServerImpl { client.waitSyncLogComplete( new TWaitSyncLogCompleteReq(targetPeer.getGroupId().convertToTConsensusGroupId())); if (res.complete) { + logger.info( + "{} SyncLog is completed. TargetIndex: {}, CurrentSyncIndex: {}", + targetPeer, + res.searchIndex, + res.safeIndex); return; } logger.info(
