fix(execute): metadata in flux statistics needs to be initialized (#4801

)
influxdata · May 27, 2022 · e107c96 · e107c96
1 parent 951b298
commit e107c96
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/execute/executor.go b/execute/executor.go
@@ -13,6 +13,7 @@ import (
 	"github.com/influxdata/flux/codes"
 	"github.com/influxdata/flux/internal/errors"
 	"github.com/influxdata/flux/memory"
+	"github.com/influxdata/flux/metadata"
 	"github.com/influxdata/flux/plan"
 	"github.com/opentracing/opentracing-go"
 	"go.uber.org/zap"
@@ -434,6 +435,7 @@ func (es *executionState) do() {
 		fn(&stats)
 	}
 
+	stats.Metadata = make(metadata.Metadata)
 	for _, src := range es.sources {
 		wg.Add(1)
 		go func(src Source) {