[core] Changelog expire should check index file existence

apache / paimon

Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.

https://paimon.apache.org/

Apache License 2.0

2.47k stars 969 forks source link

Closed leaves12138 closed 2 months ago

leaves12138 commented 2 months ago

Just two small bugs:

1 Check index file exists before read 2 Try more times for table consumer read (Rename may not be atomic)