diff --git a/lib/logstorage/filter_stream.go b/lib/logstorage/filter_stream.go
index e93a23364..5d7023ea6 100644
--- a/lib/logstorage/filter_stream.go
+++ b/lib/logstorage/filter_stream.go
@@ -57,8 +57,8 @@ func (fs *filterStream) applyToBlockResult(br *blockResult, bm *bitmap) {
 		v := c.valuesEncoded[0]
 		if !fs.f.matchStreamName(v) {
 			bm.resetBits()
-			return
 		}
+		return
 	}
 	if c.isTime {
 		bm.resetBits()
diff --git a/lib/logstorage/stream_filter.go b/lib/logstorage/stream_filter.go
index 4e3a4d2f1..2ba2109df 100644
--- a/lib/logstorage/stream_filter.go
+++ b/lib/logstorage/stream_filter.go
@@ -165,6 +165,7 @@ func (sn *streamName) parse(s string) bool {
 		if s[0] != ',' {
 			return false
 		}
+		s = s[1:]
 	}
 }