Replication may loss data when refresh recovered replication sources

    for (String queueId : previousQueueIds) {
        ReplicationSourceInterface replicationSource = createSource(queueId, peer);
        this.oldsources.add(replicationSource);
        this.queueStorage.getWALsInQueue(this.server.getServerName(), queueId)
          .forEach(wal -> src.enqueueLog(new Path(wal)));
        toStartup.add(replicationSource);
      }