learner commit when catch

ebee339d · dmchen · 9a19679b · ebee339d
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

source/libs/sync/src/syncPipeline.c source/libs/sync/src/syncPipeline.c +3 -1

未找到文件。
--- a/source/libs/sync/src/syncPipeline.c
+++ b/source/libs/sync/src/syncPipeline.c
@@ -503,7 +503,9 @@ _out:
 int32_t syncFsmExecute(SSyncNode* pNode, SSyncFSM* pFsm, ESyncState role, SyncTerm term, SSyncRaftEntry* pEntry,
                          int32_t applyCode) {
-  if (pNode->replicaNum == 1 && pNode->restoreFinish && pNode->vgId != 1) {
+  if (pNode->replicaNum == 1 &&
+      pNode->raftCfg.cfg.nodeInfo[pNode->raftCfg.cfg.myIndex].nodeRole != TAOS_SYNC_ROLE_LEARNER &&
+      pNode->restoreFinish && pNode->vgId != 1) {
    return 0;
  }