We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 01c44ec commit 46ad140Copy full SHA for 46ad140
crates/iceberg/src/transaction/mod.rs
@@ -130,10 +130,10 @@ impl Transaction {
130
}
131
132
async fn do_commit(&mut self, catalog: &dyn Catalog) -> Result<Table> {
133
- let refreshed = catalog.load_table(self.base_table.identifier()).await?;
+ let refreshed = catalog.load_table(self.table.identifier()).await?;
134
135
- if self.base_table.metadata() != refreshed.metadata()
136
- || self.base_table.metadata_location() != refreshed.metadata_location()
+ if self.table.metadata() != refreshed.metadata()
+ || self.table.metadata_location() != refreshed.metadata_location()
137
{
138
// current base is stale, use refreshed as base and re-apply transaction actions
139
self.table = refreshed.clone();
0 commit comments