Skip to content

Commit eefed5e

Browse files
author
James Cor
committed
tidy
1 parent d7396b4 commit eefed5e

File tree

1 file changed

+0
-5
lines changed

1 file changed

+0
-5
lines changed

server/handler.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -499,9 +499,6 @@ func (h *Handler) doQuery(
499499
r, processedAtLeastOneBatch, err = h.resultForValueRowIter(sqlCtx, c, schema, vr, resultFields, buf, callback, more)
500500
} else {
501501
r, processedAtLeastOneBatch, err = h.resultForDefaultIter(sqlCtx, c, schema, rowIter, callback, resultFields, more, buf)
502-
if err != nil {
503-
return remainder, err
504-
}
505502
}
506503
if err != nil {
507504
return remainder, err
@@ -669,8 +666,6 @@ func (h *Handler) resultForDefaultIter(ctx *sql.Context, c *mysql.Conn, schema s
669666
wg := sync.WaitGroup{}
670667
wg.Add(3)
671668

672-
iter, projs := GetDeferredProjections(iter)
673-
674669
// Read rows off the row iterator and send them to the row channel.
675670
var rowChan = make(chan sql.Row, 512)
676671
eg.Go(func() (err error) {

0 commit comments

Comments
 (0)