shuckle: fix CDC_WITH_REPLICAS select

This commit is contained in:
Miroslav Crnic
2024-09-11 16:30:17 +00:00
parent 824972efcd
commit 4e11e1a00b

View File

@@ -902,7 +902,7 @@ func handleCdc(log *lib.Logger, s *state, req *msgs.CdcReq) (*msgs.CdcResp, erro
func handleCdcWithReplicas(log *lib.Logger, s *state, req *msgs.CdcWithReplicasReq) (*msgs.CdcWithReplicasResp, error) {
var ret []msgs.CdcWithReplicasInfo
rows, err := s.db.Query("SELECT replica_id, ip1, port1, ip2, port2, last_seen, is_leader FROM cdc AND location_id = 0")
rows, err := s.db.Query("SELECT replica_id, ip1, port1, ip2, port2, last_seen, is_leader FROM cdc WHERE location_id = 0")
if err != nil {
return nil, fmt.Errorf("error selecting cdc replicas: %s", err)
}