diff --git a/lib/logstorage/parser.go b/lib/logstorage/parser.go
index 53b5293b57..45b3c2691d 100644
--- a/lib/logstorage/parser.go
+++ b/lib/logstorage/parser.go
@@ -717,7 +717,7 @@ func ParseQueryAtTimestamp(s string, timestamp int64) (*Query, error) {
 	// Verify the first token doesn't match pipe names.
 	firstToken := strings.ToLower(lex.rawToken)
 	if _, ok := pipeNames[firstToken]; ok {
-		return nil, fmt.Errorf("the query [%s] cannot start with pipe - it must start with madatory filter; see https://docs.victoriametrics.com/victorialogs/logsql/#query-syntax; "+
+		return nil, fmt.Errorf("the query [%s] cannot start with pipe - it must start with mandatory filter; see https://docs.victoriametrics.com/victorialogs/logsql/#query-syntax; "+
 			"if the filter isn't missing, then please put the first word of the filter into quotes: %q", s, firstToken)
 	}
 
diff --git a/lib/logstorage/pipe.go b/lib/logstorage/pipe.go
index a8dcff2a68..d2af609c1e 100644
--- a/lib/logstorage/pipe.go
+++ b/lib/logstorage/pipe.go
@@ -317,7 +317,7 @@ var pipeNames = func() map[string]struct{} {
 		"replace",
 		"replace_regexp",
 		"sort", "order",
-		"stats",
+		"stats", "by",
 		"stream_context",
 		"top",
 		"uniq",