|
|
@@ -1372,7 +1372,7 @@ func (c *Conn) awaitSchemaAgreement(ctx context.Context) (err error) {
|
|
|
}
|
|
|
|
|
|
for _, row := range rows {
|
|
|
- host, err := c.session.hostInfoFromMap(row, c.session.cfg.Port)
|
|
|
+ host, err := c.session.hostInfoFromMap(row, &HostInfo{connectAddress: c.host.ConnectAddress(), port: c.session.cfg.Port})
|
|
|
if err != nil {
|
|
|
goto cont
|
|
|
}
|