Skip to content

Commit e55c7d4

Browse files
authored
fix(query): in system.tables catalog need to disable_table_info_refresh (#18137)
* fix(query): in system.tables catalog need to disable_table_info_refresh * make clippy happy
1 parent 9432d0b commit e55c7d4

File tree

2 files changed

+9
-10
lines changed

2 files changed

+9
-10
lines changed

src/meta/kvapi/src/kvapi/test_suite.rs

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1461,16 +1461,14 @@ fn normalize_txn_response(vs: Vec<TxnOpResponse>) -> Vec<TxnOpResponse> {
14611461
_ => {}
14621462
}
14631463

1464-
match &mut v.response {
1465-
Some(Response::Put(TxnPutResponse {
1466-
current: Some(pb::SeqV { meta, .. }),
1467-
..
1468-
})) => {
1469-
if *meta == Some(pb::KvMeta { expire_at: None }) {
1470-
*meta = None;
1471-
}
1464+
if let Some(Response::Put(TxnPutResponse {
1465+
current: Some(pb::SeqV { meta, .. }),
1466+
..
1467+
})) = &mut v.response
1468+
{
1469+
if *meta == Some(pb::KvMeta { expire_at: None }) {
1470+
*meta = None;
14721471
}
1473-
_ => {}
14741472
}
14751473

14761474
v

src/query/storages/system/src/tables_table.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,8 @@ where TablesTable<WITH_HISTORY, WITHOUT_VIEW>: HistoryAware
171171
self.get_table_info().catalog(),
172172
ctx.session_state(),
173173
)
174-
.await?;
174+
.await?
175+
.disable_table_info_refresh()?;
175176

176177
// Optimization target: Fast path for known iceberg catalog SHOW TABLES
177178
if let Some((catalog_name, db_name)) =

0 commit comments

Comments
 (0)