diff --git a/beacon-chain/sync/subscriber.go b/beacon-chain/sync/subscriber.go
index 9b10790e7f..14fdeb9cd5 100644
--- a/beacon-chain/sync/subscriber.go
+++ b/beacon-chain/sync/subscriber.go
@@ -211,6 +211,9 @@ func (r *Service) subscribeDynamic(topicFormat string, determineSubsLen func() i
 				stateSub.Unsubscribe()
 				return
 			case <-stateChannel:
+				if r.chainStarted && r.initialSync.Syncing() {
+					continue
+				}
 				// Update topic count.
 				wantedSubs := determineSubsLen()
 				// Resize as appropriate.