tree 2d0ea37044fecf84a18d29b49f3c7b7f018b66b4
parent 325e463db898f586e3570b7b713199a697400022
author Prateek Maheshwari <prateekm@utexas.edu> 1679427210 -0700
committer GitHub <noreply@github.com> 1679427210 -0700
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJkGgaKCRBK7hj4Ov3rIwAAdksIAGML8C+BQW0PBx8HtTcRW1A+
 xXxGYRNa2wwUSN/Df+E/qz8ppAmCuUJAKnb2LcFE8L5LSntS8jCHoWInzyB4dCpb
 QOOz5zjfP7lRBB4/5EpHRowMy2dSX6PppGyc1g1vXgf7Fmw3Z4Yg6p3Pj1y+a9tn
 kdiCOe/G/6sKQ+RcUm2kbrDOg2DNJjZP/RzrjRn+dDse4Mw3g/qwZH1MF71Pyerp
 TRKynPACFmXc+sddMniRvku7esmZVUKONqzykqziBIJ9wKcjh9h3GRtiOLC0GpHa
 oyDCaVTN632XtTP73QsiRua6j4kTBg2bhYcv/WgaxyZcGZ+M+Xmqo7jAsyg6cGY=
 =ZXlq
 -----END PGP SIGNATURE-----
 

Side Inputs + Blob Store Backups - Part 2 - Allow bulk restore from blob store for side input stores (#1657)

Allow bulk restore from blob store for side input stores. If a blob store state backend is available, side input store restores can be sped up significantly by bulk-restoring initial state from the blob store, and only using the Kafka side input topic to catch up on the delta since last checkpoint.

Fixed a bug found during additional testing: in-memory stores configured with a changelog are not being restored correctly. The store instance created initially is retained but not restored, instead a new store instance is created and restored from changelog, and then thrown away.