From cb57f7a4a2cb4dca2fff90ec519376eb48bb8e5f Mon Sep 17 00:00:00 2001
From: Ewan Chou <coocood@gmail.com>
Date: Mon, 1 Feb 2016 15:28:32 +0800
Subject: [PATCH] executor: Close executor in join

---
 executor/executor.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/executor/executor.go b/executor/executor.go
index 9a67ccf6ef..84c1b51e6a 100644
--- a/executor/executor.go
+++ b/executor/executor.go
@@ -567,6 +567,7 @@ func (e *JoinOuterExec) Next() (*Row, error) {
 			return nil, errors.Trace(err)
 		}
 		if row == nil {
+			e.innerExec.Close()
 			e.innerExec = nil
 			if e.gotRow {
 				continue
@@ -635,6 +636,7 @@ func (e *JoinInnerExec) Next() (*Row, error) {
 			return nil, errors.Trace(err)
 		}
 		if row == nil {
+			exec.Close()
 			e.innerExecs[e.cursor] = nil
 			if e.cursor == 0 {
 				e.done = true