Fix invalid restores in storage system on crash

koralium / flowtide

Streaming integration engine

https://koralium.github.io/flowtide/

Apache License 2.0

30 stars 2 forks source link

Fix invalid restores in storage system on crash #179

Closed Ulimo closed 11 months ago

Ulimo commented 11 months ago

This removes the change to pass in a function for state options. It fixes so compaction cannot cause an invalid state. It also makes sure all state metadata is restored correctly.