diff --git a/go.mod b/go.mod index ff7c1d715..42c4480a0 100644 --- a/go.mod +++ b/go.mod @@ -56,7 +56,7 @@ require ( golang.org/x/sys v0.0.0-20210510120138-977fb7262007 // indirect golang.org/x/text v0.3.5 // indirect google.golang.org/grpc v1.28.0 - gopkg.in/yaml.v2 v2.3.0 // indirect + gopkg.in/yaml.v2 v2.3.0 modernc.org/mathutil v1.0.0 modernc.org/strutil v1.0.0 sigs.k8s.io/yaml v1.2.0 // indirect diff --git a/pg/protocol.go b/pg/protocol.go index 3ebc04934..bd58cd2d0 100644 --- a/pg/protocol.go +++ b/pg/protocol.go @@ -331,7 +331,7 @@ func (p *Portal) Parse(data []byte) { } if len(queryStr) > 2 { - + vprint.VV("SQL=[%v]", queryStr) query, err := p.mapper.MapSQL(queryStr) if err != nil { return @@ -574,6 +574,7 @@ func (p *Portal) Execute() (shouldTerminate bool, queryReady bool, err error) { case pgBegin: p.Name = "BEGIN" case pgTypeLen: + vprint.VV("adding typelen message") rowDescription, e := p.Encoder.EncodeColumn("typelen", int32(21), 2) if e != nil { err = e diff --git a/rbf/cfg/cfg.go b/rbf/cfg/cfg.go index 5f8cd9345..fb0c034f2 100644 --- a/rbf/cfg/cfg.go +++ b/rbf/cfg/cfg.go @@ -56,7 +56,7 @@ func NewDefaultConfig() *Config { MaxWALSize: DefaultMaxWALSize, MinWALCheckpointSize: DefaultMinWALCheckpointSize, MaxWALCheckpointSize: DefaultMaxWALCheckpointSize, - FsyncEnabled: true, + FsyncEnabled: false, // CI passed with 20. 50 was too big for CI, even on X-large instances. // For now we default to 0, which means use sync.Pool.