fix error check

pingcap · Jan 3, 2019 · 3eca104 · 3eca104
1 parent 9736ba3
commit 3eca104
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/executor/window.go b/executor/window.go
@@ -56,7 +56,10 @@ func (e *WindowExec) Next(ctx context.Context, chk *chunk.Chunk) error {
 	}
 	chk.Reset()
 	if e.windowFunc.HasRemainingResults() {
-		e.appendResult2Chunk(chk)
+		err := e.appendResult2Chunk(chk)
+		if err != nil {
+			return err
+		}
 	}
 	for !e.executed && (chk.NumRows() == 0 || chk.RemainedRows(chk.NumCols()-1) > 0) {
 		err := e.consumeOneGroup(ctx, chk)