fix: join engine primitive olap streaming mode execution

Signed-off-by: Harshit Gangal <[email protected]>
vitessio · Sep 18, 2023 · adb678d · adb678d
1 parent 794b912
commit adb678d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/go/vt/vtgate/engine/join.go b/go/vt/vtgate/engine/join.go
@@ -114,8 +114,8 @@ func bindvarForType(t querypb.Type) *querypb.BindVariable {
 
 // TryStreamExecute performs a streaming exec.
 func (jn *Join) TryStreamExecute(ctx context.Context, vcursor VCursor, bindVars map[string]*querypb.BindVariable, wantfields bool, callback func(*sqltypes.Result) error) error {
-	joinVars := make(map[string]*querypb.BindVariable)
 	err := vcursor.StreamExecutePrimitive(ctx, jn.Left, bindVars, wantfields, func(lresult *sqltypes.Result) error {
+		joinVars := make(map[string]*querypb.BindVariable)
 		for _, lrow := range lresult.Rows {
 			for k, col := range jn.Vars {
 				joinVars[k] = sqltypes.ValueBindVariable(lrow[col])