diff --git a/influxql/query_executor.go b/influxql/query_executor.go index ba1f6ec8cb..bc9d3ebe94 100644 --- a/influxql/query_executor.go +++ b/influxql/query_executor.go @@ -66,6 +66,9 @@ type ExecutionOptions struct { // Node to execute on. NodeID uint64 + + // Quiet suppresses non-essential output from the query executor. + Quiet bool } // ExecutionContext contains state that the query is currently executing with. @@ -226,7 +229,9 @@ func (e *QueryExecutor) executeQuery(query *Query, opt ExecutionOptions, closing } // Log each normalized statement. - e.Logger.Println(stmt.String()) + if !ctx.Quiet { + e.Logger.Println(stmt.String()) + } // Send any other statements to the underlying statement executor. err = e.StatementExecutor.ExecuteStatement(stmt, ctx)