fix corruption in new cached store implementation: keep deltas for pr…

…oper ordinal lookup
streamingfast · Mar 22, 2024 · f32e356 · f32e356
1 parent 53d5976
commit f32e356
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/pipeline/exec/storeexec.go b/pipeline/exec/storeexec.go
@@ -75,7 +75,6 @@ func (e *StoreModuleExecutor) wrapDeltas() ([]byte, *pbssinternal.ModuleOutput,
 func (e *StoreModuleExecutor) toModuleOutput(data []byte) (*pbssinternal.ModuleOutput, error) {
 	if fullkvs, ok := e.outputStore.(*store.FullKV); ok {
 		deltas := fullkvs.GetDeltas()
-		fullkvs.Reset()
 
 		return &pbssinternal.ModuleOutput{
 			Data: &pbssinternal.ModuleOutput_StoreDeltas{