diff --git a/cmd/query_benchmarker_opentsdb/main.go b/cmd/query_benchmarker_opentsdb/main.go index 9ca61fb0..d75ac44e 100644 --- a/cmd/query_benchmarker_opentsdb/main.go +++ b/cmd/query_benchmarker_opentsdb/main.go @@ -67,6 +67,9 @@ func (b *OpenTsdbQueryBenchmarker) Prepare() { } }, } + + // Make data and control channels: + b.queryChan = make(chan *Query) } func (b *OpenTsdbQueryBenchmarker) GetProcessor() bulk_query.Processor {