diff --git a/lib/protoparser/clusternative/streamparser.go b/lib/protoparser/clusternative/streamparser.go
index 0a75ffb48d..79e73c373f 100644
--- a/lib/protoparser/clusternative/streamparser.go
+++ b/lib/protoparser/clusternative/streamparser.go
@@ -50,7 +50,7 @@ func ParseStream(bc *handshake.BufferedConn, callback func(rows []storage.Metric
 				putUnmarshalWork(uw)
 				return nil
 			}
-			return fmt.Errorf("cannot read packet size: %w", err)
+			return err
 		}
 		blocksRead.Inc()
 		wg.Add(1)