Revert startReplication param change

dolthub · Feb 27, 2024 · d946736 · d946736
1 parent f22bf0f
commit d946736
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/logrepl/replication.go b/server/logrepl/replication.go
@@ -396,8 +396,8 @@ func (r *LogicalReplicator) beginReplication(slotName string) (*pgconn.PgConn, e
 	}
 
 	// LSN(0) is used to use the last confirmed LSN for this slot
-	log.Printf("Starting logical replication on slot %s from LSN %s", slotName, r.lsn)
-	err = pglogrepl.StartReplication(context.Background(), conn, slotName, r.lsn, pglogrepl.StartReplicationOptions{PluginArgs: pluginArguments})
+	log.Printf("Starting logical replication on slot %s", slotName)
+	err = pglogrepl.StartReplication(context.Background(), conn, slotName, pglogrepl.LSN(0), pglogrepl.StartReplicationOptions{PluginArgs: pluginArguments})
 	if err != nil {
 		return nil, err
 	}