set vreplication net read and net write timeout session vars to high …

…values

Signed-off-by: Olga Shestopalova <[email protected]>

go/vt/vttablet/tabletmanager/vreplication/controller.go

@@ -227,6 +227,12 @@ func (ct *controller) runBlp(ctx context.Context) (err error) {
 		if _, err := dbClient.ExecuteFetch("set names 'binary'", 10000); err != nil {
 			return err
 		}
+		if _, err := dbClient.ExecuteFetch("set @@session.net_read_timeout = 300", 10000); err != nil {
+			return err
+		}
+		if _, err := dbClient.ExecuteFetch("set @@session.net_write_timeout = 600", 10000); err != nil {
+			return err
+		}
 		// We must apply AUTO_INCREMENT values precisely as we got them. This include the 0 value, which is not recommended in AUTO_INCREMENT, and yet is valid.
 		if _, err := dbClient.ExecuteFetch("set @@session.sql_mode = CONCAT(@@session.sql_mode, ',NO_AUTO_VALUE_ON_ZERO')", 10000); err != nil {
 			return err

go/vt/vttablet/tabletserver/vstreamer/rowstreamer.go

@@ -137,6 +137,12 @@ func (rs *rowStreamer) Stream() error {
 		if _, err := rs.conn.ExecuteFetch("set names 'binary'", 1, false); err != nil {
 			return err
 		}
+		if _, err := conn.ExecuteFetch("set @@session.net_read_timeout = 300", 1, false); err != nil {
+			return err
+		}
+		if _, err := conn.ExecuteFetch("set @@session.net_write_timeout = 600", 1, false); err != nil {
+			return err
+		}
 	}
 	return rs.streamQuery(rs.send)
 }

go/vt/vttablet/tabletserver/vstreamer/tablestreamer.go

@@ -108,6 +108,12 @@ func (ts *tableStreamer) Stream() error {
 	if _, err := conn.ExecuteFetch("set names 'binary'", 1, false); err != nil {
 		return err
 	}
+	if _, err := conn.ExecuteFetch("set @@session.net_read_timeout = 300", 1, false); err != nil {
+		return err
+	}
+	if _, err := conn.ExecuteFetch("set @@session.net_write_timeout = 600", 1, false); err != nil {
+		return err
+	}
 
 	rs, err := conn.ExecuteFetch("show tables", -1, true)
 	if err != nil {