fix(store/streaming): reset BlockMetadata between blocks (#18104)

Co-authored-by: Julien Robert <[email protected]> Co-authored-by: marbar3778 <[email protected]>
cosmos · Oct 16, 2023 · 4f89b57 · 4f89b57
1 parent 3c0ab7e
commit 4f89b57
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/store/streaming/file/service.go b/store/streaming/file/service.go
@@ -161,6 +161,8 @@ func (fss *StreamingService) doListenCommit(ctx context.Context, res abci.Respon
 		if err := writeLengthPrefixedFile(path.Join(fss.writeDir, metaFileName), bz, fss.fsync); err != nil {
 			return err
 		}
+		// reset block metadata for next block so that deliverTx does not accumulate between blocks
+		fss.blockMetadata = types.BlockMetadata{}
 	}
 
 	var buf bytes.Buffer