fix(sql): Truncate unexpected columns during join

qri-io · Sep 23, 2020 · 72ec2c4 · 72ec2c4
1 parent b083482
commit 72ec2c4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/qds/datasource.go b/sql/qds/datasource.go
@@ -179,7 +179,7 @@ func (rs *RecordStream) Next(ctx context.Context) (*execution.Record, error) {
 
 	aliasedRecord := make(map[octosql.VariableName]octosql.Value)
 	if rec, ok := ent.Value.([]interface{}); ok {
-		for i, x := range rec {
+		for i, x := range rec[:len(rs.aliasedFields)] {
 			switch v := x.(type) {
 			case string:
 				aliasedRecord[rs.aliasedFields[i]] = octosql.MakeString(v)