From c834c11e2daac7c95c7351e5e5e645bc6e6bbf95 Mon Sep 17 00:00:00 2001 From: xuhuaiyu <391585975@qq.com> Date: Tue, 14 Dec 2021 15:23:49 +0800 Subject: [PATCH] address comment --- executor/join.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/executor/join.go b/executor/join.go index 164d108d74f21..09990e6c5d4b1 100644 --- a/executor/join.go +++ b/executor/join.go @@ -158,6 +158,9 @@ func (e *HashJoinExec) Close() error { // Open implements the Executor Open interface. func (e *HashJoinExec) Open(ctx context.Context) error { + if err := e.baseExecutor.Open(ctx); err != nil { + return err + } e.prepared = false e.memTracker = memory.NewTracker(e.id, -1) e.memTracker.AttachTo(e.ctx.GetSessionVars().StmtCtx.MemTracker) @@ -181,7 +184,7 @@ func (e *HashJoinExec) Open(ctx context.Context) error { } e.ctx.GetSessionVars().StmtCtx.RuntimeStatsColl.RegisterStats(e.id, e.stats) } - return e.baseExecutor.Open(ctx) + return nil } // fetchProbeSideChunks get chunks from fetches chunks from the big table in a background goroutine