address comments

pingcap · Mar 19, 2019 · 3e9f945 · 3e9f945
1 parent 6386c15
commit 3e9f945
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/executor/index_lookup_join.go b/executor/index_lookup_join.go
@@ -370,10 +370,11 @@ func (ow *outerWorker) buildTask(ctx context.Context) (*lookUpJoinTask, error) {
 	task.memTracker.AttachTo(ow.parentMemTracker)
 
 	ow.increaseBatchSize()
-	task.outerResult.SetRequiredRows(ow.batchSize, ow.maxBatchSize)
 	if ow.lookup.isOuterJoin { // if is outerJoin, push the requiredRows down
 		requiredRows := int(atomic.LoadInt64(&ow.lookup.requiredRows))
 		task.outerResult.SetRequiredRows(requiredRows, ow.maxBatchSize)
+	} else {
+		task.outerResult.SetRequiredRows(ow.batchSize, ow.maxBatchSize)
 	}
 
 	task.memTracker.Consume(task.outerResult.MemoryUsage())