diff --git a/go/vt/vttablet/tabletserver/vstreamer/rowstreamer.go b/go/vt/vttablet/tabletserver/vstreamer/rowstreamer.go index 00194b5cc0b..a75bc3079a1 100644 --- a/go/vt/vttablet/tabletserver/vstreamer/rowstreamer.go +++ b/go/vt/vttablet/tabletserver/vstreamer/rowstreamer.go @@ -133,9 +133,9 @@ func (rs *rowStreamer) Stream() error { } rs.conn = conn defer rs.conn.Close() - if _, err := rs.conn.ExecuteFetch("set names 'binary'", 1, false); err != nil { - return err - } + // if _, err := rs.conn.ExecuteFetch("set names 'binary'", 1, false); err != nil { + // return err + // } } return rs.streamQuery(rs.send) }