diff --git a/executor.go b/executor.go index bb3e2b05c..2d45c92e7 100644 --- a/executor.go +++ b/executor.go @@ -145,6 +145,7 @@ func newExecutor(opts ...executorOption) *executor { e.work = make(chan job, e.workerPoolSize) _ = testhook.Opened(NewAuditor(), e, nil) e.workers = task.NewPool(e.workerPoolSize, e.doOneJob, e) + e.frameCache = make(map[string]arrow.Table) return e }