diff --git a/api/service/synchronize/stagedstreamsync/downloader.go b/api/service/synchronize/stagedstreamsync/downloader.go
index aba23d61d5..68f339c775 100644
--- a/api/service/synchronize/stagedstreamsync/downloader.go
+++ b/api/service/synchronize/stagedstreamsync/downloader.go
@@ -320,6 +320,11 @@ func (d *Downloader) handleDownload(trigger func()) {
 
 	// if it's leader, skip syncing for now
 	if d.stagedSyncInstance.consensus != nil && d.stagedSyncInstance.consensus.IsLeader() {
+		// Retry sync after 1 seconds
+		go func() {
+			time.Sleep(1 * time.Second)
+			trigger()
+		}()
 		return
 	}