You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/10/27 08:47:25 UTC
[iotdb] 03/03: complete wait logic when migrate dataregion for ML
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 <xi...@gmail.com>
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(