Re: [I] Bug: Flink data loss after failed to refresh table [iceberg]

2024-03-26 Thread via GitHub
pvary commented on issue #9753: URL: https://github.com/apache/iceberg/issues/9753#issuecomment-2020890924 @maekchi, @Aireed: Which catalog are you using? The `SnapshotProducer` constructor uses `ops.current()` to refresh the base snapshot, like: https://github.com/apache/iceberg/

Re: [I] Bug: Flink data loss after failed to refresh table [iceberg]

2024-03-22 Thread via GitHub
maekchi commented on issue #9753: URL: https://github.com/apache/iceberg/issues/9753#issuecomment-2015318587 hello. I'm leaving a comment because I'm experiencing similar situations. I'm using iceberg 1.4.3 and flink 1.15, and I'm experiencing the same problem quite often. when ops

[I] Bug: Flink data loss after failed to refresh table [iceberg]

2024-02-19 Thread via GitHub
Aireed opened a new issue, #9753: URL: https://github.com/apache/iceberg/issues/9753 ### Apache Iceberg version 1.1.0 ### Query engine Flink ### Please describe the bug 🐞 In SnapshotProducer::commit call, if `ops.refresh()` failed, table's metadata won't