Disable multistream!

cluster/client.go

@@ -247,10 +247,12 @@ func (c *Client) Backup(br *command.BackupRequest, nodeAddr string, creds *proto
 	var rc io.ReadCloser
 	rc = conn
 	if !br.Compress {
-		rc, err = gzip.NewReader(conn)
+		gzr, err := gzip.NewReader(conn)
 		if err != nil {
 			return err
 		}
+		gzr.Multistream(false)
+		rc = gzr
 		defer rc.Close()
 	}
 	_, err = io.Copy(w, rc)

cluster/service.go

@@ -398,8 +398,8 @@ func (s *Service) handleConn(conn net.Conn) {
 			br.Compress = true
 			if err := s.db.Backup(br, conn); err != nil {
 				s.logger.Printf("failed to stream backup: %s", err.Error())
+				return
 			}
-			return // Required to signal end of stream. I do not know why. :-(
 
 		case proto.Command_COMMAND_TYPE_LOAD:
 			stats.Add(numLoadRequest, 1)